Package org.apache.geode.cache.wan

Interface GatewayQueueEvent<K,V>

All Known Subinterfaces:
AsyncEvent<K,V>
public interface GatewayQueueEvent<K,V>
Represents Cache events going through GatewaySenders.
Since:
GemFire 7.0

  • Method Summary

    Modifier and Type
    Method
    Description
    Object
    getCallbackArgument()
    Returns the callbackArgument associated with this event.
    V
    getDeserializedValue()
    Returns the deserialized value associated with this event.
    K
    getKey()
    Returns the key associated with this event.
    Operation
    getOperation()
    Returns the Operation that triggered this event.
    Region<K,V>
    getRegion()
    Returns the Region associated with this AsyncEvent
    byte[]
    getSerializedValue()
    Returns the serialized form of the value associated with this event.

  • Method Details

    • getRegion

      Region<K,V> getRegion()
      Returns the Region associated with this AsyncEvent
      Returns:
      the Region associated with this AsyncEvent OR null if Region not found (e.g. this can happen if it is destroyed).

    • getOperation

      Operation getOperation()
      Returns the Operation that triggered this event.
      Returns:
      the Operation that triggered this event

    • getCallbackArgument

      Object getCallbackArgument()
      Returns the callbackArgument associated with this event.
      Returns:
      the callbackArgument associated with this event

    • getKey

      K getKey()
      Returns the key associated with this event.
      Returns:
      the key associated with this event

    • getDeserializedValue

      V getDeserializedValue()
      Returns the deserialized value associated with this event.
      Returns:
      the deserialized value associated with this event
      Throws:
      IllegalStateException - may be thrown if the event's value was stored off-heap and AsyncEventListener.processEvents(java.util.List) has already returned.

    • getSerializedValue

      byte[] getSerializedValue()
      Returns the serialized form of the value associated with this event.
      Returns:
      the serialized form of the value associated with this event
      Throws:
      IllegalStateException - may be thrown if the event's value was stored off-heap and AsyncEventListener.processEvents(java.util.List) has already returned.