コンストラクターの詳細

• AsyncEventQueueFactoryBean

  public AsyncEventQueueFactoryBean(org.apache.geode.cache.Cache cache)

  Pivotal GemFire AsyncEventQueue を作成するための AsyncEventQueueFactoryBean のインスタンスを構築します。

  パラメーター:

  cache - Pivotal GemFire キャッシュリファレンス。

  関連事項:

  AsyncEventQueueFactoryBean(org.apache.geode.cache.Cache, org.apache.geode.cache.asyncqueue.AsyncEventListener)

• AsyncEventQueueFactoryBean

  public AsyncEventQueueFactoryBean(org.apache.geode.cache.Cache cache,
                                    org.apache.geode.cache.asyncqueue.AsyncEventListener asyncEventListener)

  Pivotal GemFire AsyncEventQueue を作成するための AsyncEventQueueFactoryBean のインスタンスを構築します。

  パラメーター:

  cache - Pivotal GemFire キャッシュリファレンス。

  asyncEventListener - 必須 AsyncEventListener

メソッドの詳細

• getObject

  public org.apache.geode.cache.asyncqueue.AsyncEventQueue getObject()
                                                              throws ExceptionSE

  例外:

  ExceptionSE

• getObjectType

  public ClassSE<?> getObjectType()

• doInit

  protected void doInit()

  次で指定:

  クラス AbstractWANComponentFactoryBean<org.apache.geode.cache.asyncqueue.AsyncEventQueue> の doInit 

• destroy

  public void destroy()

  次で指定:

  インターフェース DisposableBean 内の destroy 

  オーバーライド:

  クラス AbstractWANComponentFactoryBean<org.apache.geode.cache.asyncqueue.AsyncEventQueue> の destroy 

• setAsyncEventListener

  public final void setAsyncEventListener(org.apache.geode.cache.asyncqueue.AsyncEventListener listener)

  この FactoryBean によって作成された AsyncEventQueue に AsyncEvents がエンキューされるときに呼び出される AsyncEventListener を構成します。

  パラメーター:

  listener - 構成された AsyncEventListener。

  例外:

  IllegalStateExceptionSE - AsyncEventQueue にすでに Bean が作成されている場合。

  関連事項:

  AsyncEventListener

• getAsyncEventListener

  public org.apache.geode.cache.asyncqueue.AsyncEventListener getAsyncEventListener()

  この FactoryBean によって返される AsyncEventQueue に対して構成された AsyncEventListener を返します。

  戻り値:

  構成された AsyncEventListener。

  関連事項:

  AsyncEventListener, setAsyncEventListener(AsyncEventListener)

• setAsyncEventQueue

  public void setAsyncEventQueue(org.apache.geode.cache.asyncqueue.AsyncEventQueue asyncEventQueue)

  この FactoryBean によって返される AsyncEventQueue を構成します。

  パラメーター:

  asyncEventQueue - この FactoryBean によって返される AsyncEventQueue をオーバーライドします。

  関連事項:

  AsyncEventQueue

• getAsyncEventQueue

  public org.apache.geode.cache.asyncqueue.AsyncEventQueue getAsyncEventQueue()

  この FactoryBean によって作成された AsyncEventQueue を返します。

  戻り値:

  この FactoryBean によって作成された AsyncEventQueue への参照。

  関連事項:

  AsyncEventQueue

• setBatchConflationEnabled

  public void setBatchConflationEnabled(BooleanSE batchConflationEnabled)

  AsyncEventQueue (AEQ) メッセージの統合を有効または無効にします。

  パラメーター:

  batchConflationEnabled - キューに入れられたイベントを統合するかどうかを示す BooleanSE。

  関連事項:

  AsyncEventQueueFactory.setBatchConflationEnabled(boolean)

• setBatchSize

  public void setBatchSize(IntegerSE batchSize)

• setBatchTimeInterval

  public void setBatchTimeInterval(IntegerSE batchTimeInterval)

  バッチを送信する間の AsyncEventQueue (AEQ) 間隔を設定します。

  パラメーター:

  batchTimeInterval - IntegerSE は、バッチの送信間に経過できる最大ミリ秒数を指定します。

  関連事項:

  AsyncEventQueueFactory.setBatchTimeInterval(int)

• setDiskStoreRef

  public void setDiskStoreRef(StringSE diskStoreRef)

• setDiskSynchronous

  public void setDiskSynchronous(BooleanSE diskSynchronous)

  AsyncEventQueue (AEQ) ディスク書き込み同期ポリシーを構成します。

  パラメーター:

  diskSynchronous - ディスク書き込みが同期的かどうかを示すブール値。

  関連事項:

  AsyncEventQueueFactory.setDiskSynchronous(boolean)

• setDispatcherThreads

  public void setDispatcherThreads(IntegerSE dispatcherThreads)

  関連する AsyncEventQueue (AEQ) からの領域イベントを処理するために使用されるディスパッチャースレッドの数を構成します。

  パラメーター:

  dispatcherThreads - IntegerSE は、関連付けられたキューからの Region イベントを処理するために使用されるディスパッチャースレッドの数を指定します。

  関連事項:

  AsyncEventQueueFactory.setDispatcherThreads(int)

• setForwardExpirationDestroy

  public void setForwardExpirationDestroy(BooleanSE forwardExpirationDestroy)

  有効期限 (アクションベース) 破棄イベントを AsyncEventQueue (AEQ) に転送します。デフォルトでは、破棄イベントは AEQ に追加されません。この属性を true に設定すると、すべての有効期限破棄イベントが AEQ に追加されます。

  パラメーター:

  forwardExpirationDestroy - 有効期限破棄イベントを転送するかどうかを示すブール値。

  関連事項:

  AsyncEventQueueFactory.setForwardExpirationDestroy(boolean)、ExpirationAttributes.getAction()、ExpirationAction.DESTROY

• setGatewayEventFilters

  public void setGatewayEventFilters(ListSE<org.apache.geode.cache.wan.GatewayEventFilter> eventFilters)

• setGatewayEventSubstitutionFilter

  public void setGatewayEventSubstitutionFilter(org.apache.geode.cache.wan.GatewayEventSubstitutionFilter eventSubstitutionFilter)

• setMaximumQueueMemory

  public void setMaximumQueueMemory(IntegerSE maximumQueueMemory)

• setOrderPolicy

  public void setOrderPolicy(StringSE orderPolicy)

  AsyncEventQueue (AEQ) 順序付けポリシー (例: KEY、PARTITION、THREAD) を構成します。ディスパッチャースレッドが 1 より大きい場合、順序付けポリシーは、複数のディスパッチャースレッドがキューからのリージョンイベントを処理する方法を構成します。

  パラメーター:

  orderPolicy - AEQ オーダーポリシーの名前を指定する StringSE。

  関連事項:

  AsyncEventQueueFactory.setOrderPolicy(GatewaySender.OrderPolicy)

• setOrderPolicy

  public void setOrderPolicy(org.apache.geode.cache.wan.GatewaySender.OrderPolicy orderPolicy)

• setParallel

  public void setParallel(BooleanSE parallel)

• isParallelEventQueue

  public boolean isParallelEventQueue()

• setPauseEventDispatching

  public void setPauseEventDispatching(BooleanSE pauseEventDispatching)

• isPauseEventDispatching

  public boolean isPauseEventDispatching()

• setPersistent

  public void setPersistent(BooleanSE persistent)

• isSerialEventQueue

  public boolean isSerialEventQueue()