Class RabbitRpcQueue

java.lang.Object
com.kamikazejam.kamicommon.amqp.data.RabbitRpcQueue

public class RabbitRpcQueue extends Object
Represents a pair of client and server queues for RPC communication. Based on one queue stem, two queues are created: one for client-bound messages and one for server-bound messages.
  • Constructor Details

    • RabbitRpcQueue

      public RabbitRpcQueue(@NotNull @NotNull String queueStem)
      Creates a new pair of client and server queues based on the given queue stem.
      Parameters:
      queueStem - The stem for the queue names