org.fusesource.stompjms.channel
Class StompChannel

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

All Implemented Interfaces:

StompFrameListener

public class StompChannel
extends java.lang.Object
implements StompFrameListener

Constructor Summary

StompChannel()

Method Summary

void	ackMessage(org.fusesource.hawtbuf.AsciiBuffer consumerId, org.fusesource.hawtbuf.AsciiBuffer messageId, java.lang.Boolean sync)
void	commitTransaction()
void	connect()
StompChannel	copy()
static java.lang.String	decodeHeader(org.fusesource.hawtbuf.Buffer value)
static org.fusesource.hawtbuf.AsciiBuffer	encodeHeader(java.lang.String value)
static java.lang.String	errorMessage(StompFrame frame)
java.lang.String	getAckMode()
java.net.URI	getBrokerURI()
java.lang.String	getChannelId()
StompJmsMessageListener	getListener()
java.net.URI	getLocalURI()
java.lang.String	getPassword()
org.fusesource.hawtbuf.AsciiBuffer	getSession()
StompSocket	getSocket()
java.lang.String	getUserName()
void	initialize()
boolean	isStarted()
org.fusesource.hawtbuf.AsciiBuffer	nextId()
org.fusesource.hawtbuf.AsciiBuffer	nextId(java.lang.String prefix)
void	onFrame(StompFrame frame)
void	rollbackTransaction()
void	sendFrame(StompFrame frame)
void	sendMessage(StompJmsMessage message, boolean sync)
void	sendRequest(StompFrame frame)
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)
void	start()
org.fusesource.hawtbuf.AsciiBuffer	startTransaction()
void	stop()
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

getSession

public org.fusesource.hawtbuf.AsciiBuffer getSession()

nextId

public org.fusesource.hawtbuf.AsciiBuffer nextId()

getSocket

public StompSocket getSocket()

nextId

public org.fusesource.hawtbuf.AsciiBuffer nextId(java.lang.String prefix)

copy

public StompChannel copy()

initialize

public void initialize()
                throws javax.jms.JMSException

Throws:

javax.jms.JMSException

connect

public void connect()
             throws javax.jms.JMSException

Throws:

javax.jms.JMSException

start

public void start()
           throws javax.jms.JMSException

Throws:

javax.jms.JMSException

isStarted

public boolean isStarted()

stop

public void stop()
          throws javax.jms.JMSException

Throws:

javax.jms.JMSException

sendMessage

public void sendMessage(StompJmsMessage message,
                        boolean sync)
                 throws javax.jms.JMSException

Throws:

javax.jms.JMSException

ackMessage

public void ackMessage(org.fusesource.hawtbuf.AsciiBuffer consumerId,
                       org.fusesource.hawtbuf.AsciiBuffer messageId,
                       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()
                       throws javax.jms.JMSException

Throws:

javax.jms.JMSException

rollbackTransaction

public void rollbackTransaction()
                         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)

Specified by:

onFrame in interface StompFrameListener

errorMessage

public static java.lang.String errorMessage(StompFrame frame)

decodeHeader

public static java.lang.String decodeHeader(org.fusesource.hawtbuf.Buffer value)

encodeHeader

public static org.fusesource.hawtbuf.AsciiBuffer encodeHeader(java.lang.String value)

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)