org.fusesource.stomp.jms

Class StompChannel

java.lang.Object

org.fusesource.stomp.jms.StompChannel

public class StompChannel
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
StompChannel()

Method Summary

Methods

Modifier and Type	Method and Description
void	ackMessage(org.fusesource.hawtbuf.AsciiBuffer consumerId, org.fusesource.hawtbuf.AsciiBuffer messageId, org.fusesource.hawtbuf.AsciiBuffer txid, Promise<StompFrame> callback)
void	close()
void	commitTransaction(org.fusesource.hawtbuf.AsciiBuffer txid)
void	connect()
CallbackConnection	connection()
StompChannel	copy()
java.lang.String	getAckMode()
java.net.URI	getBrokerURI()
java.lang.String	getChannelId()
java.lang.String	getClientId()
java.lang.String	getConnectedHostId()
java.lang.String	getConnectedSessionId()
long	getDisconnectTimeout()
StompJmsMessageListener	getListener()
java.net.URI	getLocalURI()
java.lang.String	getPassword()
StompServerAdaptor	getServerAdaptor()
java.lang.String	getServerAndVersion()
javax.net.ssl.SSLContext	getSslContext()
java.lang.String	getUserName()
boolean	isOmitHost()
boolean	isStarted()
org.fusesource.hawtbuf.AsciiBuffer	nextId()
void	onFrame(StompFrame frame)
void	rollbackTransaction(org.fusesource.hawtbuf.AsciiBuffer txid)
void	sendFrame(StompFrame frame)
void	sendMessage(StompJmsMessage copy, org.fusesource.hawtbuf.AsciiBuffer txid, boolean sync)
void	sendRequest(StompFrame frame)
void	sendRequest(StompFrame frame, Promise<StompFrame> future)
org.fusesource.hawtbuf.AsciiBuffer	sessionId()
void	setAckMode(java.lang.String ackMode)
void	setBrokerURI(java.net.URI brokerURI)
void	setChannelId(java.lang.String channelId)
void	setClientId(java.lang.String clientId)
void	setDisconnectTimeout(long disconnectTimeout)
void	setExceptionListener(javax.jms.ExceptionListener listener)
void	setListener(StompJmsMessageListener listener)
void	setLocalURI(java.net.URI localURI)
void	setOmitHost(boolean omitHost)
void	setPassword(java.lang.String password)
void	setSslContext(javax.net.ssl.SSLContext sslContext)
void	setUserName(java.lang.String userName)
org.fusesource.hawtbuf.AsciiBuffer	startTransaction()
void	subscribe(StompJmsDestination destination, org.fusesource.hawtbuf.AsciiBuffer consumerId, org.fusesource.hawtbuf.AsciiBuffer selector, org.fusesource.hawtbuf.AsciiBuffer ackMode, boolean noLocal, boolean persistent, boolean browser, StompJmsPrefetch prefetch, java.util.Map<org.fusesource.hawtbuf.AsciiBuffer,org.fusesource.hawtbuf.AsciiBuffer> headers)
void	unsubscribe(org.fusesource.hawtbuf.AsciiBuffer consumerId, boolean persistent)

Methods inherited from class java.lang.Object

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

Constructor Detail

StompChannel

public StompChannel()

Method Detail

sessionId

public org.fusesource.hawtbuf.AsciiBuffer sessionId()

connection

public CallbackConnection connection()

copy

public StompChannel copy()

connect

public void connect()
             throws javax.jms.JMSException

Throws:

javax.jms.JMSException

isStarted

public boolean isStarted()

close

public void close()
           throws javax.jms.JMSException

Throws:

javax.jms.JMSException

sendMessage

public void sendMessage(StompJmsMessage copy,
               org.fusesource.hawtbuf.AsciiBuffer txid,
               boolean sync)
                 throws javax.jms.JMSException

Throws:

javax.jms.JMSException

ackMessage

public void ackMessage(org.fusesource.hawtbuf.AsciiBuffer consumerId,
              org.fusesource.hawtbuf.AsciiBuffer messageId,
              org.fusesource.hawtbuf.AsciiBuffer txid,
              Promise<StompFrame> callback)
                throws javax.jms.JMSException

Throws:

javax.jms.JMSException

subscribe

public void subscribe(StompJmsDestination destination,
             org.fusesource.hawtbuf.AsciiBuffer consumerId,
             org.fusesource.hawtbuf.AsciiBuffer selector,
             org.fusesource.hawtbuf.AsciiBuffer ackMode,
             boolean noLocal,
             boolean persistent,
             boolean browser,
             StompJmsPrefetch prefetch,
             java.util.Map<org.fusesource.hawtbuf.AsciiBuffer,org.fusesource.hawtbuf.AsciiBuffer> headers)
               throws javax.jms.JMSException

Throws:

javax.jms.JMSException

unsubscribe

public void unsubscribe(org.fusesource.hawtbuf.AsciiBuffer consumerId,
               boolean persistent)
                 throws javax.jms.JMSException

Throws:

javax.jms.JMSException

startTransaction

public org.fusesource.hawtbuf.AsciiBuffer startTransaction()
                                                    throws javax.jms.JMSException

Throws:

javax.jms.JMSException

commitTransaction

public void commitTransaction(org.fusesource.hawtbuf.AsciiBuffer txid)
                       throws javax.jms.JMSException

Throws:

javax.jms.JMSException

rollbackTransaction

public void rollbackTransaction(org.fusesource.hawtbuf.AsciiBuffer txid)
                         throws javax.jms.JMSException

Throws:

javax.jms.JMSException

sendFrame

public void sendFrame(StompFrame frame)
               throws java.io.IOException

Throws:

java.io.IOException

sendRequest

public void sendRequest(StompFrame frame,
               Promise<StompFrame> future)

sendRequest

public void sendRequest(StompFrame frame)
                 throws java.io.IOException

Throws:

java.io.IOException

onFrame

public void onFrame(StompFrame frame)

getChannelId

public java.lang.String getChannelId()

Returns:

the channelId

setChannelId

public void setChannelId(java.lang.String channelId)

Parameters:

channelId - the channelId to set

getUserName

public java.lang.String getUserName()

Returns:

the userName

setUserName

public void setUserName(java.lang.String userName)

Parameters:

userName - the userName to set

getPassword

public java.lang.String getPassword()

Returns:

the password

setPassword

public void setPassword(java.lang.String password)

Parameters:

password - the password to set

getAckMode

public java.lang.String getAckMode()

Returns:

the ackMode

setAckMode

public void setAckMode(java.lang.String ackMode)

Parameters:

ackMode - the ackMode to set

getBrokerURI

public java.net.URI getBrokerURI()

Returns:

the brokerURI

setBrokerURI

public void setBrokerURI(java.net.URI brokerURI)

Parameters:

brokerURI - the brokerURI to set

getLocalURI

public java.net.URI getLocalURI()

Returns:

the localURI

setLocalURI

public void setLocalURI(java.net.URI localURI)

Parameters:

localURI - the localURI to set

isOmitHost

public boolean isOmitHost()

setOmitHost

public void setOmitHost(boolean omitHost)

getListener

public StompJmsMessageListener getListener()

Returns:

the listener

setListener

public void setListener(StompJmsMessageListener listener)

Parameters:

listener - the listener to set

setExceptionListener

public void setExceptionListener(javax.jms.ExceptionListener listener)

nextId

public org.fusesource.hawtbuf.AsciiBuffer nextId()

getConnectedHostId

public java.lang.String getConnectedHostId()

getServerAndVersion

public java.lang.String getServerAndVersion()

getConnectedSessionId

public java.lang.String getConnectedSessionId()

getServerAdaptor

public StompServerAdaptor getServerAdaptor()

getClientId

public java.lang.String getClientId()

setClientId

public void setClientId(java.lang.String clientId)

getDisconnectTimeout

public long getDisconnectTimeout()

setDisconnectTimeout

public void setDisconnectTimeout(long disconnectTimeout)

getSslContext

public javax.net.ssl.SSLContext getSslContext()

setSslContext

public void setSslContext(javax.net.ssl.SSLContext sslContext)