Package tigase.cluster

Class AmpComponentClustered

java.lang.Object
tigase.server.BasicComponent
tigase.server.AbstractMessageReceiver
tigase.server.amp.AmpComponent
tigase.cluster.AmpComponentClustered
All Implemented Interfaces:
ClusteredComponentIfc, Configurable, XMPPService, ConfigurationChangedAware, Initializable, RegistrarBean, ActionResultsHandlerIfc, MessageReceiver, PacketWriterWithTimeout, ServerComponent, StatisticsContainer, StatisticsContainerIfc, VHostListener
@Bean(name="amp", parent=Kernel.class, active=true) @ConfigType({DefaultMode,SessionManagerMode,ConnectionManagersMode,ComponentMode}) @ClusterModeRequired(active=true) public class AmpComponentClustered extends AmpComponent implements ClusteredComponentIfc
Author:
andrzej

  • Constructor Details

    • AmpComponentClustered

      public AmpComponentClustered()

  • Method Details

    • processPacket

      public void processPacket(Packet packet)
      Description copied from class: AbstractMessageReceiver
      This is the main Packet processing method. It is called concurrently from many threads so implementing it in thread save manner is essential. The method is called for each packet addressed to the component.
      Please note, the Packet instance may be processed by different parts of the server, different components or plugins at the same time. Therefore this is very important to tread the Packet instance as unmodifiable object.
      Processing in this method is asynchronous, therefore there is no result value. If there are some 'result' packets generated during processing, they should be passed back using addOutPacket(Packet) method.
      Overrides:
      processPacket in class AmpComponent
      Parameters:
      packet - is an instance of the Packet class passed for processing.

    • setClusterController

      public void setClusterController(ClusterControllerIfc cl_controller)
      Description copied from interface: ClusteredComponentIfc
      Set's the configures the cluster controller object for cluster communication and API.
      Specified by:
      setClusterController in interface ClusteredComponentIfc
      Overrides:
      setClusterController in class BasicComponent
      Parameters:
      cl_controller - cluster controller object used for cluster communication

    • forwardPacket

      protected void forwardPacket(Packet packet)