Package com.mewna.catnip.shard.event

Class DefaultDispatchManager

java.lang.Object
com.mewna.catnip.shard.event.AbstractDispatchManager
com.mewna.catnip.shard.event.DefaultDispatchManager
All Implemented Interfaces:
DispatchManager, Closeable, AutoCloseable
public class DefaultDispatchManager extends AbstractDispatchManager

  • Constructor Details

    • DefaultDispatchManager

      public DefaultDispatchManager()

  • Method Details

    • catnip

      public void catnip(Catnip catnip)
      Specified by:
      catnip in interface DispatchManager
      Overrides:
      catnip in class AbstractDispatchManager

    • dispatchEvent

      public void dispatchEvent(String address, Object event)
      Description copied from interface: DispatchManager
      Dispatches an event to the provided address.
      Parameters:
      address - Address to send the event to.
      event - Event to dispatch.

    • createConsumer

      public <T> MessageConsumer<T> createConsumer(String address)
      Description copied from interface: DispatchManager
      Returns a consumer listening on the provided address.
      Type Parameters:
      T - Type of the event handled by the consumer.
      Parameters:
      address - Address to listen on.
      Returns:
      A consumer listening on the provided address.

    • close

      public void close()