Class RelayVelocity

java.lang.Object
com.iantapply.relay.velocity.RelayVelocity
All Implemented Interfaces:
com.iantapply.relay.api.MessagingService
public final class RelayVelocity extends Object implements com.iantapply.relay.api.MessagingService
Velocity entry point and platform-facing MessagingService implementation.

  • Constructor Summary

    Constructors
    Constructor
    Description
    RelayVelocity(com.velocitypowered.api.proxy.ProxyServer proxy, org.slf4j.Logger logger, Path dataDirectory)
    Creates the Velocity plugin instance through dependency injection.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    initialize(com.velocitypowered.api.event.proxy.ProxyInitializeEvent event)
    Starts Relay after Velocity initializes its plugins.
    <T> CompletionStage<com.iantapply.relay.api.MessageId>
    publish(com.iantapply.relay.api.Topic<T> topic, com.iantapply.relay.api.Destination destination, T payload)
     
    <T> CompletionStage<com.iantapply.relay.api.MessageId>
    publish(com.iantapply.relay.api.Topic<T> topic, com.iantapply.relay.api.Destination destination, T payload, com.iantapply.relay.api.PublishOptions options)
     
    void
    shutdown(com.velocitypowered.api.event.proxy.ProxyShutdownEvent event)
    Releases Relay resources during proxy shutdown.
    com.iantapply.relay.api.MessagingStatus
    status()
     
    <T> com.iantapply.relay.api.Subscription
    subscribe(com.iantapply.relay.api.Topic<T> topic, com.iantapply.relay.api.MessageHandler<T> handler)
     

    Methods inherited from class Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • RelayVelocity

      @Inject public RelayVelocity(com.velocitypowered.api.proxy.ProxyServer proxy, org.slf4j.Logger logger, Path dataDirectory)
      Creates the Velocity plugin instance through dependency injection.
      Parameters:
      proxy - active Velocity proxy
      logger - platform logger
      dataDirectory - plugin data directory

  • Method Details

    • initialize

      public void initialize(com.velocitypowered.api.event.proxy.ProxyInitializeEvent event)
      Starts Relay after Velocity initializes its plugins.
      Parameters:
      event - initialization event

    • shutdown

      public void shutdown(com.velocitypowered.api.event.proxy.ProxyShutdownEvent event)
      Releases Relay resources during proxy shutdown.
      Parameters:
      event - shutdown event

    • publish

      public <T> CompletionStage<com.iantapply.relay.api.MessageId> publish(com.iantapply.relay.api.Topic<T> topic, com.iantapply.relay.api.Destination destination, T payload)
      Specified by:
      publish in interface com.iantapply.relay.api.MessagingService

    • publish

      public <T> CompletionStage<com.iantapply.relay.api.MessageId> publish(com.iantapply.relay.api.Topic<T> topic, com.iantapply.relay.api.Destination destination, T payload, com.iantapply.relay.api.PublishOptions options)
      Specified by:
      publish in interface com.iantapply.relay.api.MessagingService

    • subscribe

      public <T> com.iantapply.relay.api.Subscription subscribe(com.iantapply.relay.api.Topic<T> topic, com.iantapply.relay.api.MessageHandler<T> handler)
      Specified by:
      subscribe in interface com.iantapply.relay.api.MessagingService

    • status

      public com.iantapply.relay.api.MessagingStatus status()
      Specified by:
      status in interface com.iantapply.relay.api.MessagingService