oracle.AQ
クラス AQOracleQueue

java.lang.Object
  |
  +--oracle.AQ.AQOracleQueue
 

public class AQOracleQueue

extends java.lang.Object

implements AQQueue

AQQueueのOracle Server実装。

メソッドの概要

void	addSubscriber(AQAgent subscriber, java.lang.String rule) キューにサブスクライバを追加します。
void	alterPropagationSchedule(java.lang.String destination, java.lang.Double duration, java.lang.String next_time, java.lang.Double latency) 伝播スケジュールを変更します。
void	alterQueue(AQQueueProperty q_property) キューのプロパティを変更します。
void	alterSubscriber(AQAgent subscriber, java.lang.String rule) キューのサブスクライバを変更します。
AQMessage	createMessage() 新規メッセージを作成します。ペイロードには、OBJECT_TYPE_PAYLOADまたはRAW_TYPE_PAYLOADの型を指定できます。
AQMessage	dequeue(AQDequeueOption deq_option) メッセージをデキューします。
AQMessage	dequeue(AQDequeueOption deq_option, java.lang.Class sql_data_cl)
AQMessage	dequeue(AQDequeueOption deq_option, oracle.sql.CustomDatumFactory payload_fact)
void	disablePropagationSchedule(java.lang.String destination) 伝播スケジュールを使用禁止にします。
void	drop() キューを削除します。
void	enablePropagationSchedule(java.lang.String destination) 伝播スケジュールを使用可能にします。
byte[]	enqueue(AQEnqueueOption enq_option, AQMessage message) メッセージをエンキュします。
AQSession	getAQSession() AQ接続を取得します。
java.lang.String	getName() キューの名前を取得します。
java.lang.String	getOwner() キューの所有者を取得します。
int	getPayloadType() ペイロードの型を取得します。
AQQueueProperty	getProperty() キューのプロパティを取得します。
java.lang.String	getQueueTableName() キューが常駐するキュー・テーブルの名前を取得します。
AQAgent[]	getSubscribers() キューに対するサブスクライバのリストを取得します。
void	grantQueuePrivilege(java.lang.String privilege, java.lang.String grantee) キューの権限を付与します（権限受領者に対するgrant_optionはありません）。
void	grantQueuePrivilege(java.lang.String privilege, java.lang.String grantee, boolean grant_option) キューの権限を付与します。
AQMessage	propDequeue(AQDequeueOption deq_option) キューからメッセージをプロパゲータ用にデキューします。
AQMessage	propDequeue(AQDequeueOption deq_option, java.lang.Class payload_class) キューからメッセージをデキューします。オブジェクト・ペイロードを含むキューに対してプロパゲータによって使用されます。
byte[]	propEnqueue(AQEnqueueOption enq_option, AQMessage message) メッセージをプロパゲータ用にエンキュします。
void	removeSubscriber(AQAgent subscriber) キューからサブスクライバを削除します。
void	revokeQueuePrivilege(java.lang.String privilege, java.lang.String grantee) キューの権限を取り消します。
void	schedulePropagation(java.lang.String destination, java.util.Date start_time, java.lang.Double duration, java.lang.String next_time, java.lang.Double latency) 伝播をスケジュールします。
void	start() キューに対するエンキュおよびデキューを使用可能にします。
void	start(boolean enqueue, boolean dequeue) キューに対するエンキュおよびデキューを使用可能にします。
void	startDequeue() キューに対するデキューを使用可能にします。
void	startEnqueue() キューに対するエンキュを使用可能にします。
void	stop(boolean wait) キューに対するエンキュおよびデキューを使用禁止にします。
void	stop(boolean enqueue, boolean dequeue, boolean wait) キューに対するエンキュおよびデキューを使用禁止にします。
void	stopDequeue(boolean wait) キューに対するデキューを使用禁止にします。
void	stopEnqueue(boolean wait) キューに対するエンキュを使用禁止にします。
java.lang.String	toString()
void	unschedulePropagation(java.lang.String destination) 伝播スケジュールを削除します。

クラス java.lang.Objectから継承したメソッド

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

メソッドの詳細

getOwner

public java.lang.String getOwner()
                          throws AQException 

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

定義:

インタフェース AQQueue内のgetOwner

getName

public java.lang.String getName()
                         throws AQException 

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

定義:

インタフェース AQQueue内のgetName

getAQSession

public AQSession getAQSession() 

AQ接続を取得します。

getPayloadType

public int getPayloadType()
                   throws AQException 

ペイロードの型を取得します。

getQueueTableName

public java.lang.String getQueueTableName()
                                   throws AQException 

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

定義:

インタフェース AQQueue内のgetQueueTableName

getProperty

public AQQueueProperty getProperty()
                            throws AQException 

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

定義:

インタフェース AQQueue内のgetProperty

start

public void start(boolean enqueue,
                  boolean dequeue)
           throws AQException 

キューに対するエンキュおよびデキューを使用可能にします。

start

public void start()
           throws AQException 

キューに対するエンキュおよびデキューを使用可能にします。

startEnqueue

public void startEnqueue()
                  throws AQException 

キューに対するエンキュを使用可能にします。

startDequeue

public void startDequeue()
                  throws AQException 

キューに対するデキューを使用可能にします。

stop

public void stop(boolean enqueue,
                 boolean dequeue,
                 boolean wait)
          throws AQException 

キューに対するエンキュおよびデキューを使用禁止にします。

stop

public void stop(boolean wait)
          throws AQException 

キューに対するエンキュおよびデキューを使用禁止にします。

stopEnqueue

public void stopEnqueue(boolean wait)
                 throws AQException 

キューに対するエンキュを使用禁止にします。

stopDequeue

public void stopDequeue(boolean wait)
                 throws AQException 

キューに対するデキューを使用禁止にします。

alterQueue

public void alterQueue(AQQueueProperty q_property)
                throws AQException 

キューのプロパティを変更します。

createMessage

public AQMessage createMessage()
                        throws AQException 

新規メッセージを作成します。ペイロードには、OBJECT_TYPE_PAYLOADまたはRAW_TYPE_PAYLOADの型を指定できます。

定義:

インタフェース AQQueue内のcreateMessage

drop

public void drop()
          throws AQException 

キューを削除します。

enqueue

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

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

定義:

インタフェース AQQueue内のenqueue

戻り値:

エンキュされたメッセージのID

dequeue

public AQMessage dequeue(AQDequeueOption deq_option)
                  throws AQException 

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

定義:

インタフェース AQQueue内のdequeue

戻り値:

デキューされたメッセージ

dequeue

public AQMessage dequeue(AQDequeueOption deq_option,
                         oracle.sql.CustomDatumFactory payload_fact)
                  throws AQException 

dequeue

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

定義:

インタフェース AQQueue内のdequeue

addSubscriber

public void addSubscriber(AQAgent subscriber,
                          java.lang.String rule)
                   throws AQException 

キューにサブスクライバを追加します。

removeSubscriber

public void removeSubscriber(AQAgent subscriber)
                      throws AQException 

キューからサブスクライバを削除します。

alterSubscriber

public void alterSubscriber(AQAgent subscriber,
                            java.lang.String rule)
                     throws AQException 

キューのサブスクライバを変更します。

getSubscribers

public AQAgent[] getSubscribers()
                         throws AQException 

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

定義:

インタフェース AQQueue内のgetSubscribers

schedulePropagation

public void schedulePropagation(java.lang.String destination,
                                java.util.Date start_time,
                                java.lang.Double duration,
                                java.lang.String next_time,
                                java.lang.Double latency)
                         throws AQException 

伝播をスケジュールします。

unschedulePropagation

public void unschedulePropagation(java.lang.String destination)
                           throws AQException 

伝播スケジュールを削除します。

alterPropagationSchedule

public void alterPropagationSchedule(java.lang.String destination,
                                     java.lang.Double duration,
                                     java.lang.String next_time,
                                     java.lang.Double latency)
                              throws AQException 

伝播スケジュールを変更します。

enablePropagationSchedule

public void enablePropagationSchedule(java.lang.String destination)
                               throws AQException 

伝播スケジュールを使用可能にします。

disablePropagationSchedule

public void disablePropagationSchedule(java.lang.String destination)
                                throws AQException 

伝播スケジュールを使用禁止にします。

grantQueuePrivilege

public void grantQueuePrivilege(java.lang.String privilege,
                                java.lang.String grantee,
                                boolean grant_option)
                         throws AQException 

キューの権限を付与します。

grantQueuePrivilege

public void grantQueuePrivilege(java.lang.String privilege,
                                java.lang.String grantee)
                         throws AQException 

キューの権限を付与します（権限受領者に対するgrant_optionはありません）。

revokeQueuePrivilege

public void revokeQueuePrivilege(java.lang.String privilege,
                                 java.lang.String grantee)
                          throws AQException 

キューの権限を取り消します。

propEnqueue

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

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

定義:

インタフェース AQQueue内のpropEnqueue

propDequeue

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

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

定義:

インタフェース AQQueue内のpropDequeue

propDequeue

public AQMessage propDequeue(AQDequeueOption deq_option)
                      throws AQException 

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

定義:

インタフェース AQQueue内のpropDequeue

toString

public java.lang.String toString() 

オーバーライド:

クラス java.lang.ObjectのtoString