Package org.eclipse.net4j.signal

Klasse SignalProtocol<INFRA_STRUCTURE>

java.lang.Object
org.eclipse.net4j.util.event.Notifier
org.eclipse.net4j.util.lifecycle.Lifecycle
org.eclipse.spi.net4j.Protocol<INFRA_STRUCTURE>
org.eclipse.net4j.signal.SignalProtocol<INFRA_STRUCTURE>
Alle implementierten Schnittstellen:
IBufferHandler, ILocationAware, IProtocol<INFRA_STRUCTURE>, IProtocol2<INFRA_STRUCTURE>, IProtocol3<INFRA_STRUCTURE>, ISignalProtocol<INFRA_STRUCTURE>, ISignalProtocol.WithSignalCounters<INFRA_STRUCTURE>, org.eclipse.net4j.util.collection.Entity.Store.Provider, org.eclipse.net4j.util.concurrent.IExecutorServiceProvider, org.eclipse.net4j.util.container.IManagedContainerProvider, org.eclipse.net4j.util.event.INotifier, org.eclipse.net4j.util.event.INotifier.INotifier2, org.eclipse.net4j.util.lifecycle.IDeactivateable, org.eclipse.net4j.util.lifecycle.ILifecycle, org.eclipse.net4j.util.lifecycle.ILifecycle.DeferrableActivation, org.eclipse.net4j.util.security.IUserAware
Bekannte direkte Unterklassen:
AuthenticatingSignalProtocol, HeartBeatProtocol, HeartBeatProtocol.Server
public class SignalProtocol<INFRA_STRUCTURE> extends Protocol<INFRA_STRUCTURE> implements ISignalProtocol.WithSignalCounters<INFRA_STRUCTURE>, org.eclipse.net4j.util.collection.Entity.Store.Provider
The default implementation of a signal protocol.

On the receiver side(s) of protocol the createSignalReactor() method has to be overridden to create appropriate peer instances for incoming signals.

Autor:
Eike Stepper

  • Felddetails

    • COMPRESSED_STRINGS_ACKNOWLEDGE_TIMEOUT

      public static final long COMPRESSED_STRINGS_ACKNOWLEDGE_TIMEOUT
      Seit:
      4.7

    • SIGNAL_REMOTE_EXCEPTION

      public static final short SIGNAL_REMOTE_EXCEPTION
      Seit:
      2.0
      Siehe auch:

    • SIGNAL_MONITOR_CANCELED

      public static final short SIGNAL_MONITOR_CANCELED
      Seit:
      2.0
      Siehe auch:

    • SIGNAL_MONITOR_PROGRESS

      public static final short SIGNAL_MONITOR_PROGRESS
      Seit:
      2.0
      Siehe auch:

    • SIGNAL_SET_TIMEOUT

      public static final short SIGNAL_SET_TIMEOUT
      Seit:
      4.1
      Siehe auch:

    • SIGNAL_ACKNOWLEDGE_COMPRESSED_STRINGS

      public static final short SIGNAL_ACKNOWLEDGE_COMPRESSED_STRINGS
      Seit:
      4.7
      Siehe auch:

    • SIGNAL_ENTITY

      public static final short SIGNAL_ENTITY
      Seit:
      4.20
      Siehe auch:

  • Konstruktordetails

    • SignalProtocol

      public SignalProtocol(String type)
      Seit:
      2.0

  • Methodendetails

    • getTimeout

      public long getTimeout()
      Angegeben von:
      getTimeout in Schnittstelle ISignalProtocol<INFRA_STRUCTURE>
      Seit:
      2.0

    • setTimeout

      public void setTimeout(long timeout)
      Equivalent to calling SignalProtocol.setTimeout(timeout, false).
      Angegeben von:
      setTimeout in Schnittstelle ISignalProtocol<INFRA_STRUCTURE>
      Seit:
      2.0

    • setTimeout

      public boolean setTimeout(long timeout, boolean useOldTimeoutToSendNewOne)
      Update the timeout used for signal end of stream waiting time.
      Parameter:
      timeout - the new timeout
      useOldTimeoutToSendNewOne - true to use the old timeout, false to use the new specified one to sent to server side the new specified timeout
      Gibt zurück:
      true if the new specified timeout has correctly been sent NOTE: this second parameter is useful mostly for test to be able to set a to small timeout
      Seit:
      4.4

    • getStreamWrapper

      public org.eclipse.net4j.util.io.IStreamWrapper getStreamWrapper()
      Angegeben von:
      getStreamWrapper in Schnittstelle ISignalProtocol<INFRA_STRUCTURE>

    • setStreamWrapper

      public void setStreamWrapper(org.eclipse.net4j.util.io.IStreamWrapper streamWrapper)
      Angegeben von:
      setStreamWrapper in Schnittstelle ISignalProtocol<INFRA_STRUCTURE>

    • addStreamWrapper

      public void addStreamWrapper(org.eclipse.net4j.util.io.IStreamWrapper streamWrapper)
      Angegeben von:
      addStreamWrapper in Schnittstelle ISignalProtocol<INFRA_STRUCTURE>

    • getEntityStore

      public org.eclipse.net4j.util.collection.Entity.Store getEntityStore()
      Angegeben von:
      getEntityStore in Schnittstelle org.eclipse.net4j.util.collection.Entity.Store.Provider

    • getSentSignals

      public long getSentSignals()
      Angegeben von:
      getSentSignals in Schnittstelle ISignalProtocol.WithSignalCounters<INFRA_STRUCTURE>
      Seit:
      4.13

    • getReceivedSignals

      public long getReceivedSignals()
      Angegeben von:
      getReceivedSignals in Schnittstelle ISignalProtocol.WithSignalCounters<INFRA_STRUCTURE>

    • open

      public IChannel open(IConnector connector)
      Angegeben von:
      open in Schnittstelle ISignalProtocol<INFRA_STRUCTURE>
      Seit:
      2.0

    • close

      public void close()
      Angegeben von:
      close in Schnittstelle ISignalProtocol<INFRA_STRUCTURE>
      Seit:
      2.0

    • waitForSignals

      public boolean waitForSignals(long timeout)

    • handleBuffer

      public void handleBuffer(IBuffer buffer)
      Handles a given (incoming) buffer. Creates a signal to act upon the given buffer or uses a previously created signal.
      Angegeben von:
      handleBuffer in Schnittstelle IBufferHandler
      Parameter:
      buffer - The buffer to be handled.

    • toString

      public String toString()
      Setzt außer Kraft:
      toString in Klasse org.eclipse.net4j.util.lifecycle.Lifecycle

    • doBeforeDeactivate

      protected void doBeforeDeactivate() throws Exception
      Setzt außer Kraft:
      doBeforeDeactivate in Klasse org.eclipse.net4j.util.lifecycle.Lifecycle
      Löst aus:
      Exception

    • doDeactivate

      protected void doDeactivate() throws Exception
      Setzt außer Kraft:
      doDeactivate in Klasse Protocol<INFRA_STRUCTURE>
      Löst aus:
      Exception

    • handleChannelDeactivation

      protected void handleChannelDeactivation()
      Setzt außer Kraft:
      handleChannelDeactivation in Klasse Protocol<INFRA_STRUCTURE>

    • provideSignalReactor

      protected final SignalReactor provideSignalReactor(short signalID)

    • createSignalReactor

      protected SignalReactor createSignalReactor(short signalID)
      Returns a new signal instance to serve the given signal ID or null if the signal ID is invalid/unknown for this protocol.

    • isSendingTimeoutChanges

      protected boolean isSendingTimeoutChanges()
      Returns true by default, override to change this behavior.
      Seit:
      4.1

    • getStringCompressor

      protected org.eclipse.net4j.util.io.StringCompressor getStringCompressor()
      Seit:
      4.7