|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.jboss.mq.il.oil2.OIL2ServerIL
The JVM implementation of the ServerIL object
Field Summary | |
static byte |
CLIENT_CLOSE
|
static byte |
CLIENT_DELETE_TEMPORARY_DESTINATION
|
static byte |
CLIENT_PONG
|
static byte |
CLIENT_RECEIVE
|
static byte |
RESULT_EXCEPTION
|
static byte |
RESULT_OBJECT
|
static byte |
RESULT_VOID
|
static byte |
SERVER_ACKNOWLEDGE
|
static byte |
SERVER_ADD_MESSAGE
|
static byte |
SERVER_AUTHENTICATE
|
static byte |
SERVER_BROWSE
|
static byte |
SERVER_CHECK_ID
|
static byte |
SERVER_CHECK_USER
|
static byte |
SERVER_CLOSE
|
static byte |
SERVER_CONNECTION_CLOSING
|
static byte |
SERVER_CREATE_QUEUE
|
static byte |
SERVER_CREATE_TOPIC
|
static byte |
SERVER_DELETE_TEMPORARY_DESTINATION
|
static byte |
SERVER_DESTROY_SUBSCRIPTION
|
static byte |
SERVER_GET_ID
|
static byte |
SERVER_GET_TEMPORARY_QUEUE
|
static byte |
SERVER_GET_TEMPORARY_TOPIC
|
static byte |
SERVER_PING
|
static byte |
SERVER_RECEIVE
|
static byte |
SERVER_SET_ENABLED
|
static byte |
SERVER_SET_SPY_DISTRIBUTED_CONNECTION
|
static byte |
SERVER_SUBSCRIBE
|
static byte |
SERVER_TRANSACT
|
static byte |
SERVER_UNSUBSCRIBE
|
Constructor Summary | |
OIL2ServerIL(String addr,
int port,
String socketFactoryName,
boolean enableTcpNoDelay)
Constructor for the OILServerIL object |
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 OILServerIL object |
String |
authenticate(String userName,
String password)
#Description of the Method |
SpyMessage[] |
browse(ConnectionToken dc,
javax.jms.Destination dest,
String selector)
#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 |
close()
Used to close the current connection with the server |
void |
connect()
|
void |
connectionClosing(ConnectionToken dc)
#Description of the Method |
javax.jms.Queue |
createQueue(ConnectionToken dc,
String dest)
#Description of the Method |
javax.jms.Topic |
createTopic(ConnectionToken dc,
String dest)
#Description of the Method |
void |
deleteTemporaryDestination(ConnectionToken dc,
SpyDestination dest)
#Description of the Method |
void |
destroySubscription(ConnectionToken dc,
DurableSubscriptionID id)
#Description of the Method |
String |
getID()
Gets the ID attribute of the OILServerIL object |
javax.jms.TemporaryQueue |
getTemporaryQueue(ConnectionToken dc)
Gets the TemporaryQueue attribute of the OILServerIL object |
javax.jms.TemporaryTopic |
getTemporaryTopic(ConnectionToken dc)
Gets the TemporaryTopic attribute of the OILServerIL 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 OILServerIL object |
void |
setEnabled(ConnectionToken dc,
boolean enabled)
Sets the Enabled attribute of the OILServerIL 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 |
public static final byte RESULT_VOID
public static final byte RESULT_OBJECT
public static final byte RESULT_EXCEPTION
public static final byte CLIENT_RECEIVE
public static final byte CLIENT_DELETE_TEMPORARY_DESTINATION
public static final byte CLIENT_CLOSE
public static final byte CLIENT_PONG
public static final byte SERVER_ACKNOWLEDGE
public static final byte SERVER_ADD_MESSAGE
public static final byte SERVER_BROWSE
public static final byte SERVER_CHECK_ID
public static final byte SERVER_CONNECTION_CLOSING
public static final byte SERVER_CREATE_QUEUE
public static final byte SERVER_CREATE_TOPIC
public static final byte SERVER_DELETE_TEMPORARY_DESTINATION
public static final byte SERVER_GET_ID
public static final byte SERVER_GET_TEMPORARY_QUEUE
public static final byte SERVER_GET_TEMPORARY_TOPIC
public static final byte SERVER_RECEIVE
public static final byte SERVER_SET_ENABLED
public static final byte SERVER_SET_SPY_DISTRIBUTED_CONNECTION
public static final byte SERVER_SUBSCRIBE
public static final byte SERVER_TRANSACT
public static final byte SERVER_UNSUBSCRIBE
public static final byte SERVER_DESTROY_SUBSCRIPTION
public static final byte SERVER_CHECK_USER
public static final byte SERVER_PING
public static final byte SERVER_CLOSE
public static final byte SERVER_AUTHENTICATE
Constructor Detail |
public OIL2ServerIL(String addr, int port, String socketFactoryName, boolean enableTcpNoDelay)
Method Detail |
public void connect() throws IOException
IOException
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 dest) throws javax.jms.JMSException, Exception
createQueue
in interface ServerIL
dc
- Description of Parameterdest
- Description of Parameter
javax.jms.JMSException
- Description of Exception
Exception
- Description of Exceptionpublic javax.jms.Topic createTopic(ConnectionToken dc, String dest) throws javax.jms.JMSException, Exception
createTopic
in interface ServerIL
dc
- Description of Parameterdest
- Description of Parameter
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
- Description of ParametersubscriptionId
- Description of Parameter
javax.jms.JMSException
- Description of Exception
Exception
- Description of Exceptionpublic void close()
Exception
- Description of Exception
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |