<repository>	<id>com.thefirstlineofcode.release</id>	<name>TheFirstLineOfCode Repository - Releases</name>	<url>http://repo.thefirstlineofcode.com/content/repositories/releases</url> </repository> 

<dependency>	<groupId>com.thefirstlineofcode.chalk</groupId>	<artifactId>com.thefirstlineofcode.chalk</artifactId>	<version>0.2.0-RELEASE</version> </dependency> 

<dependency>	<groupId>com.thefirstlineofcode.chalk.xeps</groupId>	<artifactId>com.thefirstlineofcode.chalk.xeps.ibr</artifactId>	<version>0.2.0-RELEASE</version> </dependency> 

StreamConfig config = new StreamConfig("im.thefirstlineofcode.com", 5222); config.setResource("my_android_mobile"); IChatClient chatClient = new StandardChatClient(config); try {	chatClient.connect("my_user_name", "my_password"); } catch (ConnectionException e) {	throw new RuntimeException("can't connect to host", e); } catch (AuthFailureException e) {	throw new RuntimeException("auth failed", e); } 

chatClient.addNegotiationListener(new INegotiationListsener() {	public void before(IStreamNegotiant source) {	if (source instanceof TlsNegotiation) {	System.out.println("Ready to negotiate TLS");	}	}	public void after(IStreamNegotiant source) {	if (source instanceof TlsNegotiation) {	System.out.println("TLS negotiation has done");	}	}	public void occurred(NegotiationException exception) {	IStreamNegotiant source = exception.getSource();	if (source instnaceof SaslNegotiant) {	SaslError saslError = (SaslError)exception.getAdditionalErrorInfo();	System.out.println("Error occured in SASL negotiation. Additional error info: " + saslError);	}	}	public void done(IStream stream) {	System.out.println("Stream has created");	} }); chatClient.connect("my_user_name", "my_password"); 

((StandardChatClient)chatClient).setPeerCertificateTruster(new IPeerCertificateTruster() {	public boolean accept(X509Certificate[] certificates) {	// check certificates	}	} ); 

chatClient.register(PingPlugin.class); 

public interface IPing {	public enum Result {	PONG,	SERVICE_UNAVAILABLE,	TIME_OUT	}	Result ping();	void setTimeout(int timeout);	int getTimeout(); } 

IPing ping = chatClient.createApi(IPing.class); 

ping.setTimeout(4 * 1000); // Set timeout to the ping operation. Default is 2 * 1000ms. Result result = ping.ping(); // Ping the server and waiting for result. if (result == Ping.Result.PONG) {	System.out.println("Pong."); } else if (result == SERVICE_UNAVAILABLE) {	System.out.println("Server doesn't support the protocol."); } else {	System.out.println("Ping timed out."); } 

chaClient.register(IbrPlugin.class); 

try {	IRegistration registration = chatClient.createApi(IRegistration.class);	registration.register(new IRegistrationCallback() {	public Object fillOut(IqRegister iqRegister) {	if (iqRegister.getRegister() instanceof RegistrationForm) {	RegistrationForm form = new RegistrationForm();	form.getFields().add(new RegistrationField("username", "my_user_name"));	form.getFields().add(new RegistrationField("password", "my_password"));	return form;	} else {	throw new RuntimeException("Can't get registration form");	}	}	}); } catch(RegistrationException e) {	IbrError error = e.getError();	if (error instanceof IbrError.Conflict) {	System.out.println("User has existed. Please change your name.");	} else if (error instanceof IbrError.NOT_ACCEPTABLE) {	System.out.println("Illegal user name. Please change your name.");	} else {	System.out.println("Registration failed.");	} } 

chaClient.register(InstantingMessengerPlugin.class); 

IInstantingMessenger im = chatClient.createApi(IInstantingMessenger.class); im.send(new Presence()); // Send initial presence 

Presence presence = new Presence(Show.DND); presence.getStatuses().add(new LangText("I'm being in a meeting.")); im.send(presence); 

im.addPresenceListener(new IPresenceListener() {	public void received(Presence presence) {	System.out.println("Contact " + presence.getFrom() + " changed it's presence to " + presence.toString());	} }); 

IRosterService rosterService = im.getRosterService(); rosterService.addRosterListener(new IRosterListener() {	void retrieved(Roster roster) {	// Process the roster that is retrieved from server.	}	void occurred(RosterError error) {	// An error occurred	}	... }); rosterService.retrieve(); 

rosterService.addRosterListener(new IRosterListener() {	...	public void updated(Roster roster) {	// Process the updated roster	}	public void deleted(Roster roster) {	// process the deleted roster	}	... }); 

public interface IRosterService {	...	void add(Roster roster);	void update(Roster roster);	void delete(Roster roster);	... } 

JabberId contact = JabberId.parse("smartsheep@im.thefirstlineofcode.com"); ISubscriptionService subscriptionService = im.getSubscriptionService(); subscriptionService.subscribe(contact); 

subscriptionService.addSubscriptionListener(new ISubscriptionListener() {	...	public void asked(JabberId user) {	System.out.println("User " + user + " wants to subscribe you.");	}	... }); 

subscriptionService.approve(contact); 

subscriptionService.refuse(contact); 

subscriptionService.addSubscriptionListener(new ISubscriptionListener() {	...	public void approved(JabberId contact) {	System.out.println("User " + contact + " approved your subscription.");	}	public void refused(JabberId contact) {	System.out.println("User " + user + " refused your subscription.");	}	... }); 

JabberId contact = JabberId.parse("agilest@im.thefirstlineofcode.com"); Message message = new Message("Hello, Agilest!"); message.setTo(contact); im.send(message); 

JabberId contact = JabberId.parse("agilest@im.thefirstlineofcode.com"); im.send(contact, new Message("Hello, Agilest!")) 

im.addMessageListener(new IMessageListener() {	public void received(Message message) {	System.out.println("Received a message from user " + message.getFrom());	} }); 

chaClient.register(InstantingMessengerPlugin2.class); 

IInstantingMessenger2 im2 = chatClient.createApi(IInstantingMessenger2.class); im2.addMessageListener(new IMessageListener2() {	public void received(Message message) {	System.out.println("Received a message from user " + message.getFrom());	}	public void traced(Trace trace) {	for (MsgStatus status : trace.getMsgStatuses()) {	if (status.getStatus() == MsgStatus.Status.SERVER_REACHED) {	System.out.println("Message which id is " + status.getId() + " has reached server at time " + status.getStamp());	} else if (status.getStatus() == MsgStatus.Status.PEER_REACHED) {	System.out.println("Message which id is " + status.getId() + " has reached peer at time " + status.getStamp());	} else { // status.getStatus() == MsgStatus.Status.MESSAGE_READ	System.out.println("Message which id is " + status.getId() + " has read by contact at time " + status.getStamp());	}	}	} }); 

chaClient.register(MucPlugin.class); 

IMucService muc = chatClient.createApi(IMucService.class); JabberId[] hosts = muc.getMucHosts(); 

JabberId[] rooms = muc.getMucRooms(); 

IRoom room = muc.getRoom(roomJid); 

RoomInfo roomInfo = room.getRoomInfo(); 

room.enter("my_nick_name"); 

room.exit(); 

Occupant[] occupants = room.getOccupants(); 

room.send(new Message("Hello, everyone!")); 

room.send("user_nick_name", new Message("Hello, everyone!")); 

JabberId roomJid = JabberId.parse("my_chat_room_name@im.thefirstlineofcode.com"); muc.createInstantRoom(roomJid, "my_nick_name"); 

JabberId roomJid = JabberId.parse("my_chat_room_name@im.thefirstlineofcode.com"); muc.createReservedRoom(roomJid, "my_nick_name", new StandardRoomConfigurator() {	protected RoomConfig configure(RoomConfig roomConfig) {	roomConfig.setRoomName("my first room");	roomConfig.setRoomDesc("Hope you have happy hours here!");	roomConfig.setMembersOnly(true);	roomConfig.setAllowInvites(true);	roomConfig.setPasswordProtectedRoom(true);	roomConfig.setRoomSecret("simple_password");	roomConfig.getGetMemberList().setParticipant(false);	roomConfig.getGetMemberList().setVisitor(false);	roomConfig.setWhoIs(WhoIs.MODERATORS);	roomConfig.setModeratedRoom(true);	return roomConfig;	} } ); 

JabberId myColleague = JabberId.parse("my_colleague_name@im.thefirstlineofcode.com"); room.invite(myColleague, "Let's discuss our plan") 

muc.addRoomListener(new IRoomListener() {	public void received(RoomEvent<?> event) {	if (event instanceof InvitationEvent) {	InvitationEvent invitationEvent = (InvitationEvent)event;	JabberId roomJid = invitationEvent.getRoomJid();	Invitation invitation = invitationEvent.getEventObject();	System.out.println(String.format("'%s' invites you to join room '%s'", invitation.getInvitor(), roomJid));	} else if (event instanceof EnterEvent) {	Enter enter = ((EnterEvent)event).getEventObject();	Occupant occupant = muc.getRoom(event.getRoomJid()).getOccupant(enter.getNick());	int sessions = occupant == null ? 0 : occupant.getSessions();	System.out.println(String.format("'%s'[sessions:%d] has joined room '%s'", enter.getNick(), sessions, event.getRoomJid()));	} else if (event instanceof ExitEvent) {	Exit exit = ((ExitEvent)event).getEventObject();	Occupant occupant = muc.getRoom(event.getRoomJid()).getOccupant(exit.getNick());	int sessions = occupant == null ? 0 : occupant.getSessions();	System.out.println(String.format("'%s'[sessions:%d] has exited room '%s'", exit.getNick(), sessions, event.getRoomJid()));	} else if (event instanceof ChangeAvailabilityStatusEvent) {	ChangeAvailabilityStatus changeAvailabilityStatus = ((ChangeAvailabilityStatusEvent)event).getEventObject();	System.out.println(String.format("'%s' has changed it's availability status to: %s", changeAvailabilityStatus.getNick(),	getAvailabilityStatus(changeAvailabilityStatus)));	} else if (event instanceof RoomMessageEvent) {	RoomMessageEvent messageEvent = (RoomMessageEvent)event;	System.out.println(String.format("groupchat message received[from '%s' at room '%s']: %s", messageEvent.getEventObject().getNick(),	messageEvent.getRoomJid(), messageEvent.getEventObject().getMessage()));	} else if (event instanceof PrivateMessageEvent) {	PrivateMessageEvent privateMessageEvent = (PrivateMessageEvent)event;	System.out.println(String.format("groupchat private message received[from '%s' at room '%s']: %s", privateMessageEvent.getEventObject().getNick(),	privateMessageEvent.getRoomJid(), privateMessageEvent.getEventObject().getMessage()));	} else if (event instanceof DiscussionHistoryEvent) {	DiscussionHistoryEvent discussionHistoryEvent = (DiscussionHistoryEvent)event;	System.out.println(String.format("groupchat discussion history message received[from '%s' at room '%s']: %s", discussionHistoryEvent.getEventObject().getNick(),	discussionHistoryEvent.getRoomJid(), discussionHistoryEvent.getEventObject().getMessage()));	} else if (event instanceof ChangeNickEvent) {	ChangeNickEvent changeNickEvent = (ChangeNickEvent)event;	System.out.println(String.format("user '%s'[sessions: %d] changed his nick[at room '%s']: %s", changeNickEvent.getEventObject().getOldNick(),	changeNickEvent.getEventObject().getOldNickSessions(), changeNickEvent.getRoomJid(),	changeNickEvent.getEventObject().getNewNick()));	} else if (event instanceof RoomSubjectEvent) {	RoomSubjectEvent roomSubjectEvent = (RoomSubjectEvent)event;	if ("".equals(roomSubjectEvent.getEventObject().getSubject())) {	System.out.println(String.format("there are no room subject in room '%s'", roomSubjectEvent.getRoomJid()));	} else {	System.out.println(String.format("room subject received[from '%s' in room '%s']: %s", roomSubjectEvent.getEventObject().getNick(),	roomSubjectEvent.getRoomJid(), roomSubjectEvent.getEventObject().getSubject()));	}	} else if (event instanceof KickedEvent) {	KickedEvent kickedEvent = (KickedEvent)event;	System.out.println(String.format("you are kicked by '%s' from room '%s'. reason is '%s'", kickedEvent.getEventObject().getNick(),	kickedEvent.getEventObject().getActor().getNick(), kickedEvent.getRoomJid(),	kickedEvent.getEventObject().getReason()));	} else if (event instanceof KickEvent) {	KickEvent kickEvent = (KickEvent)event;	System.out.println(String.format("'%s' is kicked from room '%s'", kickEvent.getEventObject().getNick(), kickEvent.getRoomJid()));	}	} }); 

<iq from='juliet@capulet.lit/balcony' to='capulet.lit' id='c2s1' type='get'>	<ping xmlns='urn:xmpp:ping'/> </iq> 

<iq from='capulet.lit' to='juliet@capulet.lit/balcony' id='c2s1' type='result'/> 

<iq from='capulet.lit' to='juliet@capulet.lit/balcony' id='c2s1' type='error'>	<ping xmlns='urn:xmpp:ping'/>	<error type='cancel'>	<service-unavailable xmlns='urn:ietf:params:xml:ns:xmpp-stanzas'/>	</error> </iq> 

public class Ping {	public static final Protocol PROTOCOL = new Protocol("urn:xmpp:ping", "ping"); } 

public interface IPing {	public enum Result {	PONG, // Server returned a pong.	SERVICE_UNAVAILABLE, // Server doesn't support the protocol.	TIME_OUT // Ping timed out.	}	/** * Send a ping request to server and waiting for result. */	Result ping();	/** * Set timeout for ping operation. */	void setTimeout(int timeout);	/** * Get the ping timeout. */	int getTimeout(); } 

IIqService iqService = chatServices.getIqService(); Iq ping = new Iq(Iq.Type.GET); ping.setObject(new Ping()); String pingId = ping.getId(); iqService.send(ping); 

iqService.addListener(new IIqListener() {	public void received(Iq iq) {	if (pingId.equals(iq.getId()) {	// Received response from server	}	} }); 

IErrorService errorService = chatServices.getErrorService(); errorService.addListener(new IErrorListener() {	public void occurred(IError error) {	if (pingId.equals(error.getId()) {	if (error instanceof ServerUnavailable) {	// Received server-unavailable error from server	}	}	} }); 

Timer timer = new Timer(); timer.schedule(pingTimeoutTask, timeout); 

public class PingImpl implements IPing {	private IChatServices chatServices;	private String id;	private int timeout;	public Result ping() {	SyncOperationTemplate<Iq, IPing.Result> template = new SyncOperationTemplate<Iq, IPing.Result>(chatServices);	try {	return template.execute(new ISyncIqOperation<IPing.Result>() {	public void trigger(IUnidirectionalStream<Iq> stream) {	Iq iq = new Iq(Iq.Type.SET);	iq.setObject(new Ping());	id = iq.getId();	stream.send(iq, timeout);	}	public boolean isErrorOccurred(StanzaError error) {	if (id.equals(error.getId()))	return true;	return false;	}	public boolean isResultReceived(Iq iq) {	if (id.equals(iq.getId()))	return true;	return false;	}	public Result processResult(Iq iq) {	return IPing.Result.PONG;	}	});	} catch (ErrorException e) {	if (e.getError().getDefinedCondition().equals(RemoteServerTimeout.DEFINED_CONDITION)) {	return IPing.Result.TIME_OUT;	} else {	return IPing.Result.SERVICE_UNAVAILABLE;	}	}	}	}	... } 

public class PingImpl implements IPing {	private IChatServices chatServices;	private int timeout;	...	public Result ping() {	ITaskService taskService = chatServices.getTaskService();	try {	return taskService.execute(new ISyncTask<Iq, IPing.Result>() {	public void trigger(IUnidirectionalStream<Iq> stream) {	Iq iq = new Iq(Iq.Type.SET);	iq.setObject(new Ping());	stream.send(iq, timeout);	}	public Result processResult(Iq iq) {	return IPing.Result.PONG;	}	});	} catch (ErrorException e) {	if (e.getError().getDefinedCondition().equals(RemoteServerTimeout.DEFINED_CONDITION)) {	return IPing.Result.TIME_OUT;	} else {	return IPing.Result.SERVICE_UNAVAILABLE;	}	}	}	... } 

public interface ITaskService {	...	void execute(ITask<?> task);	... } 

public class PingPlugin implements IPlugin {	public void init(IChatSystem chatSystem, Properties properties) {	chatSystem.registerParser(	ProtocolChain.first(Iq.PROTOCOL).next(Ping.PROTOCOL),	new SimpleObjectParserFactory<Ping>(Ping.PROTOCOL, Ping.class));	chatSystem.registerTranslator(	Ping.class,	new SimpleObjectTranslatorFactory<Ping>(Ping.class, Ping.PROTOCOL));	chatSystem.registerApi(IPing.class, PingImpl.class, properties);	}	public void destroy(IChatSystem chatSystem) {	chatSystem.unregisterApi(IPing.class);	chatSystem.unregisterTranslator(Ping.class);	chatSystem.unregisterParser(ProtocolChain.first(Iq.PROTOCOL).next(Ping.PROTOCOL));	} } 

chatClient.register(PingPlugin.class); 

IPing ping = chatClient.createApi(IPing.class); 

IPing.Result result = ping.ping();