Interface Spin<T>

Type Parameters:
T - the type of the payload object

public interface Spin<T>
Interface used to implement a Spin that will be used to define the kind of deserialization and how the message must be consumed by the consumer configured

The implementation must also be MessageConsumer annotated


 @MessageConsumer(deserializer = JsonDeserializer.class,  schema = TestMessage.class)
 public TestSpin implements Spin<TestMessage>; {
     @Override
     public void consume(TestMessage message, MessageContext messageContext) throws SpinException{
          ...
     }
 }
 
  • Method Summary

    Modifier and Type
    Method
    Description
    void
    consume(T message, MessageContext messageContext)
    Consume the given message
  • Method Details

    • consume

      void consume(T message, MessageContext messageContext) throws SpinException
      Consume the given message
      Parameters:
      message - deserialized to consume
      messageContext - message information context
      Throws:
      SpinException - in case of any error during the consuming of this message