com.caucho.message.stomp

Class StompConnection

java.lang.Object

com.caucho.network.listen.AbstractProtocolConnection

com.caucho.message.stomp.StompConnection

All Implemented Interfaces:

ProtocolConnection

public class StompConnection
extends AbstractProtocolConnection

Custom serialization for the cache

Method Summary

Modifier and Type	Method and Description
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