|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.jboss.mq.il.uil2.UILServerIL
The UILServerIL is created on the server and copied to the client during connection factory lookups. It represents the transport interface to the JMS server.
Field Summary | |
protected Socket |
socket
Description of the Field |
protected SocketManager |
socketMgr
Description of the Field |
Fields inherited from interface org.jboss.mq.il.uil2.msgs.MsgTypes |
m_acknowledge, m_addMessage, m_authenticate, m_browse, m_checkID, m_checkUser, m_close, m_connectionClosing, m_createQueue, m_createTopic, m_deleteTemporaryDestination, m_destroySubscription, m_getID, m_getTemporaryQueue, m_getTemporaryTopic, m_ping, m_pong, m_receive, m_receiveRequest, m_setEnabled, m_setSpyDistributedConnection, m_subscribe, m_transact, m_unsubscribe |
Constructor Summary | |
UILServerIL(InetAddress addr,
int port,
String socketFactoryName,
boolean enableTcpNoDelay,
int bufferSize,
int chunkSize)
|
Method Summary | |
void |
acknowledge(ConnectionToken dc,
AcknowledgementRequest item)
#Description of the Method |
void |
addMessage(ConnectionToken dc,
SpyMessage val)
Adds a feature to the Message attribute of the UILServerIL object |
String |
authenticate(String username,
String password)
Authenticate the user |
SpyMessage[] |
browse(ConnectionToken dc,
javax.jms.Destination dest,
String selector)
#Description of the Method |
protected void |
checkConnection()
#Description of the Method |
void |
checkID(String id)
#Description of the Method |
String |
checkUser(String username,
String password)
#Description of the Method |
Object |
clone()
#Description of the Method |
ServerIL |
cloneServerIL()
Need to clone because there are instance variables tha can get clobbered. |
void |
connectionClosing(ConnectionToken dc)
#Description of the Method |
protected void |
createConnection()
Used to establish a new connection to the server |
javax.jms.Queue |
createQueue(ConnectionToken dc,
String destName)
#Description of the Method |
javax.jms.Topic |
createTopic(ConnectionToken dc,
String destName)
#Description of the Method |
void |
deleteTemporaryDestination(ConnectionToken dc,
SpyDestination dest)
#Description of the Method |
protected void |
destroyConnection()
Used to close the current connection with the server |
void |
destroySubscription(ConnectionToken dc,
DurableSubscriptionID id)
#Description of the Method |
String |
getID()
Gets the ID attribute of the UILServerIL object |
javax.jms.TemporaryQueue |
getTemporaryQueue(ConnectionToken dc)
Gets the TemporaryQueue attribute of the UILServerIL object |
javax.jms.TemporaryTopic |
getTemporaryTopic(ConnectionToken dc)
Gets the TemporaryTopic attribute of the UILServerIL object |
void |
ping(ConnectionToken dc,
long clientTime)
#Description of the Method |
SpyMessage |
receive(ConnectionToken dc,
int subscriberId,
long wait)
#Description of the Method |
void |
setConnectionToken(ConnectionToken dest)
Sets the ConnectionToken attribute of the UILServerIL object |
void |
setEnabled(ConnectionToken dc,
boolean enabled)
Sets the Enabled attribute of the UILServerIL object |
void |
subscribe(ConnectionToken dc,
Subscription s)
#Description of the Method |
void |
transact(ConnectionToken dc,
TransactionRequest t)
#Description of the Method |
void |
unsubscribe(ConnectionToken dc,
int subscriptionID)
#Description of the Method |
Methods inherited from class java.lang.Object |
equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected transient Socket socket
protected transient SocketManager socketMgr
Constructor Detail |
public UILServerIL(InetAddress addr, int port, String socketFactoryName, boolean enableTcpNoDelay, int bufferSize, int chunkSize) throws Exception
addr
- port
- socketFactoryName
- enableTcpNoDelay
- bufferSize
- chunkSize
-
Exception
Method Detail |
public void setConnectionToken(ConnectionToken dest) throws Exception
setConnectionToken
in interface ServerIL
dest
- The new ConnectionToken value
Exception
- Description of Exceptionpublic void setEnabled(ConnectionToken dc, boolean enabled) throws javax.jms.JMSException, Exception
setEnabled
in interface ServerIL
dc
- The new Enabled valueenabled
- The new Enabled value
javax.jms.JMSException
- Description of Exception
Exception
- Description of Exceptionpublic String getID() throws Exception
Exception
- Description of Exceptionpublic javax.jms.TemporaryQueue getTemporaryQueue(ConnectionToken dc) throws javax.jms.JMSException, Exception
getTemporaryQueue
in interface ServerIL
dc
- Description of Parameter
javax.jms.JMSException
- Description of Exception
Exception
- Description of Exceptionpublic javax.jms.TemporaryTopic getTemporaryTopic(ConnectionToken dc) throws javax.jms.JMSException, Exception
getTemporaryTopic
in interface ServerIL
dc
- Description of Parameter
javax.jms.JMSException
- Description of Exception
Exception
- Description of Exceptionpublic void acknowledge(ConnectionToken dc, AcknowledgementRequest item) throws javax.jms.JMSException, Exception
acknowledge
in interface ServerIL
dc
- Description of Parameteritem
- Description of Parameter
javax.jms.JMSException
- Description of Exception
Exception
- Description of Exceptionpublic void addMessage(ConnectionToken dc, SpyMessage val) throws Exception
addMessage
in interface ServerIL
dc
- The feature to be added to the Message attributeval
- The feature to be added to the Message attribute
Exception
- Description of Exceptionpublic SpyMessage[] browse(ConnectionToken dc, javax.jms.Destination dest, String selector) throws javax.jms.JMSException, Exception
dc
- Description of Parameterdest
- Description of Parameterselector
- Description of Parameter
javax.jms.JMSException
- Description of Exception
Exception
- Description of Exceptionpublic void checkID(String id) throws javax.jms.JMSException, Exception
id
- Description of Parameter
javax.jms.JMSException
- Description of Exception
Exception
- Description of Exceptionpublic String checkUser(String username, String password) throws javax.jms.JMSException, Exception
username
- Description of Parameterpassword
- Description of Parameter
javax.jms.JMSException
- Description of Exception
Exception
- Description of Exceptionpublic String authenticate(String username, String password) throws javax.jms.JMSException, Exception
authenticate
in interface ServerIL
username
- Description of Parameterpassword
- Description of Parameter
javax.jms.JMSException
- Description of Exception
Exception
- Description of Exceptionpublic Object clone() throws CloneNotSupportedException
CloneNotSupportedException
- Description of Exceptionpublic ServerIL cloneServerIL() throws Exception
cloneServerIL
in interface ServerIL
Exception
- Description of Exceptionpublic void connectionClosing(ConnectionToken dc) throws javax.jms.JMSException, Exception
connectionClosing
in interface ServerIL
dc
- Description of Parameter
javax.jms.JMSException
- Description of Exception
Exception
- Description of Exceptionpublic javax.jms.Queue createQueue(ConnectionToken dc, String destName) throws javax.jms.JMSException, Exception
createQueue
in interface ServerIL
dc
- - the destination connection tokendestName
- - the name of the destination
javax.jms.JMSException
- Description of Exception
Exception
- Description of Exceptionpublic javax.jms.Topic createTopic(ConnectionToken dc, String destName) throws javax.jms.JMSException, Exception
createTopic
in interface ServerIL
dc
- - the destination connection tokendestName
- - the name of the destination
javax.jms.JMSException
- Description of Exception
Exception
- Description of Exceptionpublic void deleteTemporaryDestination(ConnectionToken dc, SpyDestination dest) throws javax.jms.JMSException, Exception
deleteTemporaryDestination
in interface ServerIL
dc
- Description of Parameterdest
- Description of Parameter
javax.jms.JMSException
- Description of Exception
Exception
- Description of Exceptionpublic void destroySubscription(ConnectionToken dc, DurableSubscriptionID id) throws javax.jms.JMSException, Exception
destroySubscription
in interface ServerIL
id
- Description of Parameter
javax.jms.JMSException
- Description of Exception
Exception
- Description of Exceptionpublic void ping(ConnectionToken dc, long clientTime) throws Exception
dc
- Description of ParameterclientTime
- Description of Parameter
Exception
- Description of Exceptionpublic SpyMessage receive(ConnectionToken dc, int subscriberId, long wait) throws Exception, Exception
dc
- Description of ParametersubscriberId
- Description of Parameterwait
- Description of Parameter
Exception
- Description of Exceptionpublic void subscribe(ConnectionToken dc, Subscription s) throws javax.jms.JMSException, Exception
dc
- Description of Parameters
- Description of Parameter
javax.jms.JMSException
- Description of Exception
Exception
- Description of Exceptionpublic void transact(ConnectionToken dc, TransactionRequest t) throws javax.jms.JMSException, Exception
dc
- Description of Parametert
- Description of Parameter
javax.jms.JMSException
- Description of Exception
Exception
- Description of Exceptionpublic void unsubscribe(ConnectionToken dc, int subscriptionID) throws javax.jms.JMSException, Exception
unsubscribe
in interface ServerIL
dc
- - the destination connection tokensubscriptionID
- Description of Parameter
javax.jms.JMSException
- Description of Exception
Exception
- Description of Exceptionprotected void checkConnection() throws Exception
Exception
- Description of Exceptionprotected void createConnection() throws Exception
Exception
- Description of Exceptionprotected void destroyConnection()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |