|
||||||||
前のクラス 次のクラス | フレームあり フレームなし | |||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |
java.lang.Objectorg.pslx.Messaging.QueueManager
public class QueueManager
JMS(Java Message Service)によるメッセージ通信を支援するクラス
コンストラクタの概要 | |
---|---|
QueueManager()
JMS(Java Message Service)によるメッセージ通信を支援するクラスを生成します。 |
メソッドの概要 | |
---|---|
void |
connect()
メッセージブローカへ接続します。 |
javax.jms.QueueSession |
createQueueSession()
キューセッションを生成します。 |
void |
disconnect()
メッセージブローカから切断します。 |
javax.jms.QueueConnection |
getConnection()
メッセージブローカとの接続を表すQueueConnectionを取得します |
javax.jms.Queue |
getQueue(java.lang.String queueName)
指定した名前のキューを取得します |
java.lang.String |
getSenderId()
送信者を表す識別子を取得します。 |
int |
getSleepingInterval()
要求メッセージに対する応答メッセージを待ち受ける際に、到着確認する間隔をミリ秒単位で取得します。 |
int |
getTimeOutLength()
要求メッセージに対する応答メッセージを待ち受ける際に、タイムアウトとする時間をミリ秒単位で取得します。 |
boolean |
isConnected()
メッセージブローカと接続されているかどうかを取得します。 |
java.lang.String |
receiveMessage(java.lang.String receiveQueueName)
指定したキューにメッセージが存在する場合、メッセージを取得します。 |
java.lang.String |
request(java.lang.String text,
java.lang.String requestQueueName,
java.lang.String responseQueueName)
指定したキューに対して要求メッセージを送信します。 |
javax.jms.Message |
requestAsync(java.lang.String text,
java.lang.String requestQueueName,
java.lang.String responseQueueName)
指定したキューに対して要求メッセージを送信します。 |
javax.jms.Message |
send(java.lang.String text,
java.lang.String toQueueName)
メッセージを指定したキューへ送信します。 |
javax.jms.Message |
sendResponseOf(javax.jms.Message requestMessage,
java.lang.String text)
指定した要求メッセージに対する応答メッセージを送信します。 |
void |
setSenderId(java.lang.String id)
送信者を表す識別子を設定します。 |
void |
setSleepingInterval(int value)
要求メッセージに対する応答メッセージを待ち受ける際に、到着確認する間隔をミリ秒単位で指定します。 |
void |
setTimeOutLength(int value)
要求メッセージに対する応答メッセージを待ち受ける際に、タイムアウトとする時間をミリ秒単位で指定します。 |
クラス java.lang.Object から継承されたメソッド |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
コンストラクタの詳細 |
---|
public QueueManager()
メソッドの詳細 |
---|
public javax.jms.Message send(java.lang.String text, java.lang.String toQueueName) throws javax.jms.JMSException, javax.naming.NamingException
text
- 送信するメッセージtoQueueName
- 送信先のキューの名称(JNDIで宣言された名称)
javax.jms.JMSException
javax.naming.NamingException
public javax.jms.Message sendResponseOf(javax.jms.Message requestMessage, java.lang.String text) throws javax.jms.JMSException, javax.naming.NamingException, PpsMessagingException
requestMessage
- 要求メッセージ(この要求メッセージに対する応答メッセージを生成します)text
- 送信する応答メッセージ
javax.jms.JMSException
javax.naming.NamingException
PpsMessagingException
public java.lang.String request(java.lang.String text, java.lang.String requestQueueName, java.lang.String responseQueueName) throws PpsMessagingException, javax.jms.JMSException, javax.naming.NamingException
MessageManager
の記述:
MessageManager
内の request
text
- 送信するメッセージrequestQueueName
- 要求メッセージを送るキューの名称(JNDIで宣言された名称)responseQueueName
- 応答メッセージを受け取るキューの名称(JNDIで宣言された名称)
PpsMessagingException
javax.jms.JMSException
javax.naming.NamingException
public javax.jms.Message requestAsync(java.lang.String text, java.lang.String requestQueueName, java.lang.String responseQueueName) throws java.lang.Exception
text
- 送信するメッセージrequestQueueName
- 送信先のキューの名称(JNDIで宣言された名称)responseQueueName
- 応答メッセージを受け取るキューの名称(JNDIで宣言された名称)
java.lang.Exception
public void connect()
MessageManager
の記述:
MessageManager
内の connect
public void disconnect()
MessageManager
の記述:
MessageManager
内の disconnect
public boolean isConnected()
MessageManager
の記述:
MessageManager
内の isConnected
public void setSenderId(java.lang.String id)
MessageManager
の記述:
MessageManager
内の setSenderId
public java.lang.String getSenderId()
MessageManager
の記述:
MessageManager
内の getSenderId
public javax.jms.QueueConnection getConnection()
public java.lang.String receiveMessage(java.lang.String receiveQueueName) throws javax.jms.JMSException, javax.naming.NamingException, PpsMessagingException
MessageManager
の記述:
MessageManager
内の receiveMessage
receiveQueueName
- メッセージを確認するキュー(JNDIで宣言された名称)
javax.jms.JMSException
javax.naming.NamingException
PpsMessagingException
public javax.jms.Queue getQueue(java.lang.String queueName) throws javax.naming.NamingException
queueName
- キューの名称(JNDIで宣言された名称)
javax.naming.NamingException
public javax.jms.QueueSession createQueueSession() throws javax.jms.JMSException
javax.jms.JMSException
public int getSleepingInterval()
public void setSleepingInterval(int value) throws PpsMessagingException
value
- 時間(ミリ秒単位)
PpsMessagingException
public int getTimeOutLength()
MessageManager
の記述:
MessageManager
内の getTimeOutLength
public void setTimeOutLength(int value)
MessageManager
の記述:
MessageManager
内の setTimeOutLength
value
- 時間(ミリ秒単位)
|
||||||||
前のクラス 次のクラス | フレームあり フレームなし | |||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |