Deserialization method from the interface. Automatically deserializes any type based on the AMQP encoding. The downside is that since it can deseriali

Deserializes an AMQP string as a Java UTF-8 string. @param data AMQP-encoded bytes @return String @throws IllegalArgumentException if the bytes do

Deserializes an AMQP symbol as a Java string. @param data AMQP-encoded bytes @return String @throws IllegalArgumentException if the bytes do not re

Deserialize any of the AMQP floating point types. Return the value as a double, which can represent the range of any of the smaller types. @param dat

Deserialize any of the AMQP signed integer types. Return the value as a long, which can represent the range of any of the smaller types. @param data

Deserialize any of the AMQP unsigned integer types. Because Java does not support unsigned, return the value as a long, which can represent the unsign

The only supported described type is a URI, which has a string value. @return the value of the described type

Deserializes an AMQP boolean (0x41, 0x42). @param data AMQP-encoded bytes @return boolean represented by the bytes @throws IllegalArgumentExceptio

Deserializes a single UTF32 character. Java does not support UTF32 directly but has library support to convert it to (potentially multi-byte sequences

Deserializes an AMQP described type (0x00). @param data AMQP-encoded bytes @return DecribedType encapsulates the descriptor and value which make up

Deserializes an AMQP timestamp as a Java Instant in UTC timezone. @param data AMQP-encoded bytes @return Instant representing the AMQP timestamp @t

Deserializes a UUID. @param data AMQP-encoded bytes @return UUID @throws IllegalArgumentException if the bytes do not represent the AMQP UUID type

The only supported described type has descriptor "com.microsoft:uri" @return the descriptor of the described type

Required by the Deserializer<> interface, but this deserializer has nothing to do on close.

NewTokenProvider creates a new sarama.AccessTokenProvider with the provided clientID and clientSecret. The provided tokenURL is used to perform the 2

NewTokenProvider creates a new sarama.AccessTokenProvider with the provided clientID and clientSecret. The provided tokenURL is used to perform the 2