org.fusesource.stompjms
Class StompChannel

java.lang.Object
  org.fusesource.stompjms.StompChannel

public class StompChannel
extends java.lang.Object

Constructor Summary

StompChannel()

Method Summary

void	ackMessage(org.fusesource.hawtbuf.AsciiBuffer consumerId, org.fusesource.hawtbuf.AsciiBuffer messageId, org.fusesource.hawtbuf.AsciiBuffer txid, java.lang.Boolean sync)
void	close()
void	commitTransaction(org.fusesource.hawtbuf.AsciiBuffer txid)
void	connect()
Connection	connection()
StompChannel	copy()
java.lang.String	getAckMode()
java.net.URI	getBrokerURI()
java.lang.String	getChannelId()
StompJmsMessageListener	getListener()
java.net.URI	getLocalURI()
java.lang.String	getPassword()
java.lang.String	getUserName()
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 message, org.fusesource.hawtbuf.AsciiBuffer txid, boolean sync)
void	sendRequest(StompFrame frame)
org.fusesource.hawtbuf.AsciiBuffer	sessionId()
void	setAckMode(java.lang.String ackMode)
void	setBrokerURI(java.net.URI brokerURI)
void	setChannelId(java.lang.String channelId)
void	setExceptionListener(javax.jms.ExceptionListener listener)
void	setListener(StompJmsMessageListener listener)
void	setLocalURI(java.net.URI localURI)
void	setPassword(java.lang.String password)
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, boolean clientAck, boolean persistent, boolean browser)
void	unsubscribe(StompJmsDestination destination, org.fusesource.hawtbuf.AsciiBuffer consumerId, boolean persistent, boolean browser)

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 Connection 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 message,
                        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,
                       java.lang.Boolean sync)
                throws javax.jms.JMSException

Throws:

javax.jms.JMSException

subscribe

public void subscribe(StompJmsDestination destination,
                      org.fusesource.hawtbuf.AsciiBuffer consumerId,
                      org.fusesource.hawtbuf.AsciiBuffer selector,
                      boolean clientAck,
                      boolean persistent,
                      boolean browser)
               throws javax.jms.JMSException

Throws:

javax.jms.JMSException

unsubscribe

public void unsubscribe(StompJmsDestination destination,
                        org.fusesource.hawtbuf.AsciiBuffer consumerId,
                        boolean persistent,
                        boolean browser)
                 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)
                 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

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()