public final class PulsarMessageUtils extends Object
Modifier and Type | Method and Description |
---|---|
static byte[] |
serialize(Object body) |
static org.apache.camel.Exchange |
updateExchange(org.apache.pulsar.client.api.Message<byte[]> message,
org.apache.camel.Exchange input) |
static org.apache.camel.Exchange |
updateExchangeWithException(Exception exception,
org.apache.camel.Exchange input) |
public static org.apache.camel.Exchange updateExchange(org.apache.pulsar.client.api.Message<byte[]> message, org.apache.camel.Exchange input)
public static org.apache.camel.Exchange updateExchangeWithException(Exception exception, org.apache.camel.Exchange input)
public static byte[] serialize(Object body) throws IOException
IOException
Apache Camel