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(StompJmsDestination destination, java.lang.String consumerId, java.lang.String messageId)
void	commitTransaction()
void	connect()
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()
void	initialize()
boolean	isStarted()
void	onFrame(StompFrame frame)
void	rollbackTransaction()
void	sendFrame(StompFrame frame)
void	sendMessage(StompJmsMessage message)
void	sendMessageRequest(StompJmsMessage message)
void	sendRequest(java.lang.String id, 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()
java.lang.String	startTransaction()
void	stop()
void	subscribe(StompJmsDestination destination, java.lang.String consumerId, java.lang.String selector, boolean clientAck, boolean persistent)
void	unsubscribe(StompJmsDestination destination, java.lang.String 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

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)
                 throws javax.jms.JMSException

Throws:

javax.jms.JMSException

sendMessageRequest

public void sendMessageRequest(StompJmsMessage message)
                        throws javax.jms.JMSException

Throws:

javax.jms.JMSException

ackMessage

public void ackMessage(StompJmsDestination destination,
                       java.lang.String consumerId,
                       java.lang.String messageId)
                throws javax.jms.JMSException

Throws:

javax.jms.JMSException

subscribe

public void subscribe(StompJmsDestination destination,
                      java.lang.String consumerId,
                      java.lang.String selector,
                      boolean clientAck,
                      boolean persistent)
               throws javax.jms.JMSException

Throws:

javax.jms.JMSException

unsubscribe

public void unsubscribe(StompJmsDestination destination,
                        java.lang.String consumerId,
                        boolean persistent,
                        boolean browser)
                 throws javax.jms.JMSException

Throws:

javax.jms.JMSException

startTransaction

public java.lang.String 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(java.lang.String id,
                        StompFrame frame)
                 throws java.io.IOException

Throws:

java.io.IOException

onFrame

public void onFrame(StompFrame frame)

Specified by:

onFrame in interface StompFrameListener

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)