Class PublishToQueue

    • Field Detail

      • queueName

        private String queueName
      • exchangeName

        private String exchangeName
      • routingKey

        private String routingKey
      • body

        private byte[] body
      • serverId

        private short serverId
      • proxyId

        private long proxyId
      • immediate

        private boolean immediate
      • channelNumber

        private int channelNumber
    • Constructor Detail

      • PublishToQueue

        public PublishToQueue​(String queueName,
                              String exchangeName,
                              String routingKey,
                              boolean immediate,
                              AMQP.Basic.BasicProperties properties,
                              byte[] body,
                              int channelNumber,
                              short serverId,
                              long proxyId)
    • Method Detail

      • isImmediate

        public boolean isImmediate()
      • getRoutingKey

        public String getRoutingKey()
      • getBody

        public byte[] getBody()
      • getServerId

        public short getServerId()
      • getProxyId

        public long getProxyId()
      • getQueueName

        public String getQueueName()
      • getExchangeName

        public String getExchangeName()
      • getChannelNumber

        public int getChannelNumber()
      • getMessage

        public Message getMessage()