Class IncomingPublishEvent


  • public class IncomingPublishEvent
    extends Object
    An event that describes an incoming publish message received on a streaming operation.
    • Method Detail

      • getPayload

        public byte[] getPayload()
        Gets the payload of the IncomingPublishEvent.
        Returns:
        Payload of the IncomingPublishEvent.
      • getTopic

        public String getTopic()
        Gets the topic of the IncomingPublishEvent.
        Returns:
        Topic of the IncomingPublishEvent.
      • getContentType

        public String getContentType()
        Gets the content type of the IncomingPublishEvent.
        Returns:
        Content type of the IncomingPublishEvent.
      • getUserProperties

        public List<UserProperty> getUserProperties()
        Gets the user properties of the IncomingPublishEvent.
        Returns:
        User properties of the IncomingPublishEvent.
      • getMessageExpiryIntervalSeconds

        public Long getMessageExpiryIntervalSeconds()
        Gets the message expiry interval seconds of the IncomingPublishEvent.
        Returns:
        Message expiry interval seconds of the IncomingPublishEvent.