oracle.AQ
インタフェース AQQueue

既知の実装クラスの一覧:

AQOracleQueue

public abstract interface AQQueue

extends AQQueueAdmin

AQのキュー操作インタフェース。

メソッドの概要

AQMessage	createMessage() 新規メッセージを作成します。
AQMessage	dequeue(AQDequeueOption deq_option) キューからRAWメッセージをデキューします。
AQMessage	dequeue(AQDequeueOption deq_option, java.lang.Class payload_class) キューからメッセージをデキューします。オブジェクト・ペイロードpayload_classを含むキューで使用されます。デキューされたペイロードは、この型のオブジェクトとして格納されます。使用するAQドライバによっては、ペイロードに指定できるクラスの型に制限がある場合があります。
byte[]	enqueue(AQEnqueueOption enq_option, AQMessage message) メッセージをエンキュします。
java.lang.String	getName() キューの名前を取得します。
java.lang.String	getOwner() キューの所有者を取得します。
AQQueueProperty	getProperty() キューのプロパティを取得します。
java.lang.String	getQueueTableName() キューが常駐するキュー・テーブルの名前を取得します。
AQAgent[]	getSubscribers() キューに対するサブスクライバのリストを取得します。
AQMessage	propDequeue(AQDequeueOption deq_option) キューからメッセージをプロパゲータ用にデキューします。
AQMessage	propDequeue(AQDequeueOption deq_option, java.lang.Class payload_class) キューからメッセージをデキューします。オブジェクト・ペイロードを含むキューに対してプロパゲータによって使用されます。
byte[]	propEnqueue(AQEnqueueOption enq_option, AQMessage message) メッセージをプロパゲータ用にエンキュします。

インタフェースoracle.AQ.AQQueueAdminから継承されるメソッド

addSubscriber, alterPropagationSchedule, alterQueue, alterSubscriber, disablePropagationSchedule, drop, enablePropagationSchedule, grantQueuePrivilege, grantQueuePrivilege, removeSubscriber, revokeQueuePrivilege, schedulePropagation, start, start, startDequeue, startEnqueue, stop, stop, stopDequeue, stopEnqueue, unschedulePropagation

メソッドの詳細

getOwner

public java.lang.String getOwner()
                          throws AQException 

キューの所有者を取得します。

getName

public java.lang.String getName()
                         throws AQException 

キューの名前を取得します。

getQueueTableName

public java.lang.String getQueueTableName()
                                   throws AQException 

キューが常駐するキュー・テーブルの名前を取得します。

getProperty

public AQQueueProperty getProperty()
                            throws AQException 

キューのプロパティを取得します。

createMessage

public AQMessage createMessage()
                        throws AQException 

新規メッセージを作成します。

enqueue

public byte[] enqueue(AQEnqueueOption enq_option,
                      AQMessage message)
               throws AQException 

メッセージをエンキュします。

propEnqueue

public byte[] propEnqueue(AQEnqueueOption enq_option,
                          AQMessage message)
                   throws AQException 

メッセージをプロパゲータ用にエンキュします。

dequeue

public AQMessage dequeue(AQDequeueOption deq_option)
                  throws AQException 

キューからRAWメッセージをデキューします。

dequeue

public AQMessage dequeue(AQDequeueOption deq_option,
                         java.lang.Class payload_class)
                  throws AQException 

キューからメッセージをデキューします。オブジェクト・ペイロードpayload_classを含むキューで使用されます。デキューされたペイロードは、この型のオブジェクトとして格納されます。使用するAQドライバによっては、ペイロードに指定できるクラスの型に制限がある場合があります。クラスが指定されない場合、オブジェクトはAQStructDataとして取得されます。

propDequeue

public AQMessage propDequeue(AQDequeueOption deq_option)
                      throws AQException 

キューからメッセージをプロパゲータ用にデキューします。

propDequeue

public AQMessage propDequeue(AQDequeueOption deq_option,
                             java.lang.Class payload_class)
                      throws AQException 

キューからメッセージをデキューします。オブジェクト・ペイロードを含むキューに対してプロパゲータによって使用されます。

getSubscribers

public AQAgent[] getSubscribers()
                         throws AQException 

キューに対するサブスクライバのリストを取得します。