com.caucho.message.stomp
Class StompConnection

java.lang.Object
  extended by com.caucho.network.listen.AbstractProtocolConnection
      extended by com.caucho.message.stomp.StompConnection
All Implemented Interfaces:
ProtocolConnection

public class StompConnection
extends AbstractProtocolConnection

Custom serialization for the cache


Method Summary
 boolean abort(java.lang.String tid)
           
 boolean ack(java.lang.String sid, long mid)
           
 boolean begin(java.lang.String tid)
           
 boolean commit(java.lang.String tid)
           
 SenderSettleHandler createReceiptCallback()
           
 long getContentLength()
           
 java.lang.String getContentType()
           
 BrokerSender getDestination()
           
 java.lang.String getId()
           
 long getMessageId()
           
 java.lang.String getProtocolRequestURL()
          Returns a default debugging identifier for the connection
 java.lang.String getReceipt()
           
 long getSessionId()
           
 java.lang.String getSubscription()
           
 java.lang.String getTransaction()
           
 long getXid()
           
 boolean handleRequest()
          Handles a new connection.
 boolean handleResume()
          Handles a resumption of the connection for an async/comet request.
 void init()
          Initialize the connection.
 boolean isWaitForRead()
          Return true if the connection should wait for a read before handling the request.
 boolean nack(java.lang.String sid, long mid)
           
 void onCloseConnection()
          Handles a close event when the connection is closed.
 void onStartConnection()
          Called when the connection starts, i.e.
 boolean subscribe()
           
 boolean unsubscribe(java.lang.String id)
           
 
Methods inherited from class com.caucho.network.listen.AbstractProtocolConnection
onAttachThread, onDetachThread
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Method Detail

getProtocolRequestURL

public java.lang.String getProtocolRequestURL()
Description copied from class: AbstractProtocolConnection
Returns a default debugging identifier for the connection

Specified by:
getProtocolRequestURL in interface ProtocolConnection
Overrides:
getProtocolRequestURL in class AbstractProtocolConnection

init

public void init()
Description copied from class: AbstractProtocolConnection
Initialize the connection. At this point, the current thread is the connection thread.

Specified by:
init in interface ProtocolConnection
Overrides:
init in class AbstractProtocolConnection

getSessionId

public long getSessionId()

getContentLength

public long getContentLength()

getMessageId

public long getMessageId()

getSubscription

public java.lang.String getSubscription()

getContentType

public java.lang.String getContentType()

getDestination

public BrokerSender getDestination()

getId

public java.lang.String getId()

getXid

public long getXid()
Returns:

getReceipt

public java.lang.String getReceipt()

createReceiptCallback

public SenderSettleHandler createReceiptCallback()

getTransaction

public java.lang.String getTransaction()

subscribe

public boolean subscribe()
                  throws java.io.IOException
Throws:
java.io.IOException

unsubscribe

public boolean unsubscribe(java.lang.String id)

ack

public boolean ack(java.lang.String sid,
                   long mid)

nack

public boolean nack(java.lang.String sid,
                    long mid)

begin

public boolean begin(java.lang.String tid)

commit

public boolean commit(java.lang.String tid)

abort

public boolean abort(java.lang.String tid)

handleRequest

public boolean handleRequest()
                      throws java.io.IOException
Description copied from class: AbstractProtocolConnection
Handles a new connection. The controlling TcpServer may call handleConnection again after the connection completes, so the implementation must initialize any variables for each connection.

Specified by:
handleRequest in interface ProtocolConnection
Specified by:
handleRequest in class AbstractProtocolConnection
Throws:
java.io.IOException

handleResume

public boolean handleResume()
                     throws java.io.IOException
Description copied from class: AbstractProtocolConnection
Handles a resumption of the connection for an async/comet request.

Specified by:
handleResume in interface ProtocolConnection
Overrides:
handleResume in class AbstractProtocolConnection
Throws:
java.io.IOException

isWaitForRead

public boolean isWaitForRead()
Description copied from interface: ProtocolConnection
Return true if the connection should wait for a read before handling the request.


onCloseConnection

public void onCloseConnection()
Description copied from class: AbstractProtocolConnection
Handles a close event when the connection is closed.

Specified by:
onCloseConnection in interface ProtocolConnection
Overrides:
onCloseConnection in class AbstractProtocolConnection

onStartConnection

public void onStartConnection()
Description copied from interface: ProtocolConnection
Called when the connection starts, i.e. just after the accept

Specified by:
onStartConnection in interface ProtocolConnection
Overrides:
onStartConnection in class AbstractProtocolConnection