org.jboss.aerogear.sync.server.gcm

Class GcmDiffSyncHandler<T,S extends Edit<? extends Diff>>

java.lang.Object

org.jboss.aerogear.sync.server.gcm.GcmDiffSyncHandler<T,S>

All Implemented Interfaces:

org.jivesoftware.smack.PacketListener

public class GcmDiffSyncHandler<T,S extends Edit<? extends Diff>>
extends Object
implements org.jivesoftware.smack.PacketListener

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	connectionDraining Indicates whether the connection is in draining state, which means that it will not accept any new downstream messages.

Constructor Summary

Constructors

Constructor and Description
GcmDiffSyncHandler(ServerSyncEngine<T,S> syncEngine, org.jivesoftware.smack.XMPPConnection connection)

Method Summary

Modifier and Type	Method and Description
protected static String	createJsonAck(String to, String messageId) Creates a JSON encoded ACK message for an upstream message received from an application.
protected void	handleAckReceipt(com.fasterxml.jackson.databind.JsonNode jsonObject) Handles an ACK.
protected void	handleControlMessage(com.fasterxml.jackson.databind.JsonNode jsonObject)
protected void	handleNackReceipt(com.fasterxml.jackson.databind.JsonNode jsonObject) Handles a NACK.
protected void	messageReceived(com.fasterxml.jackson.databind.JsonNode json)
void	processPacket(org.jivesoftware.smack.packet.Packet packet)
protected void	send(String jsonRequest) Sends a packet with contents provided.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

connectionDraining

protected volatile boolean connectionDraining

Indicates whether the connection is in draining state, which means that it will not accept any new downstream messages.

Constructor Detail

GcmDiffSyncHandler

public GcmDiffSyncHandler(ServerSyncEngine<T,S> syncEngine,
                          org.jivesoftware.smack.XMPPConnection connection)

Method Detail

handleAckReceipt

protected void handleAckReceipt(com.fasterxml.jackson.databind.JsonNode jsonObject)

Handles an ACK.

Logs a INFO message, but subclasses could override it to properly handle ACKs.

Parameters:

jsonObject - the messageObject

handleNackReceipt

protected void handleNackReceipt(com.fasterxml.jackson.databind.JsonNode jsonObject)

Handles a NACK.

Logs a INFO message, but subclasses could override it to properly handle NACKs.

Parameters:

jsonObject - the messageObject

handleControlMessage

protected void handleControlMessage(com.fasterxml.jackson.databind.JsonNode jsonObject)

createJsonAck

protected static String createJsonAck(String to,
                                      String messageId)

Creates a JSON encoded ACK message for an upstream message received from an application.

Parameters:

to - RegistrationId of the device who sent the upstream message.

messageId - messageId of the upstream message to be acknowledged to CCS.

Returns:

JSON encoded ack.

processPacket

public void processPacket(org.jivesoftware.smack.packet.Packet packet)

Specified by:

processPacket in interface org.jivesoftware.smack.PacketListener

messageReceived

protected void messageReceived(com.fasterxml.jackson.databind.JsonNode json)
                        throws Exception

Throws:

Exception

send

protected void send(String jsonRequest)
             throws org.jivesoftware.smack.SmackException.NotConnectedException

Sends a packet with contents provided.

Parameters:

jsonRequest - the request in JSON format

Throws:

SmackException.NotConnectedException - if not connected