Package akka.javasdk.testkit

Interface EventingTestKit.IncomingMessages

Enclosing interface:
EventingTestKit
public static interface EventingTestKit.IncomingMessages
Allows to simulate publishing messages for the purposes of testing incoming message flow.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    publish(byte[] message)
    Simulate the publishing of a raw message.
    void
    publish(byte[] message, akka.javasdk.Metadata metadata)
    Simulate the publishing of a raw message.
    void
    publish(EventingTestKit.Message<?> message)
    Simulate the publishing of a message.
    void
    publish(com.google.protobuf.ByteString message)
    Deprecated.
    Use publish with byte array parameter
    void
    publish(com.google.protobuf.ByteString message, akka.javasdk.Metadata metadata)
    Deprecated.
    Use publish with byte array parameter
    void
    publish(List<EventingTestKit.Message<?>> messages)
    Publish multiple messages.
    <T> void
    publish(T message, String subject)
    Simulate the publishing of a message.
    void
    publishDelete(String subject)
    Publish a predefined delete message.

  • Method Details

    • publish

      @Deprecated void publish(com.google.protobuf.ByteString message)
      Deprecated.
      Use publish with byte array parameter
      Simulate the publishing of a raw message.
      Parameters:
      message - raw protobuf bytestring to be published

    • publish

      @Deprecated void publish(com.google.protobuf.ByteString message, akka.javasdk.Metadata metadata)
      Deprecated.
      Use publish with byte array parameter
      Simulate the publishing of a raw message.
      Parameters:
      message - raw protobuf bytestring to be published
      metadata - associated with the message

    • publish

      void publish(byte[] message)
      Simulate the publishing of a raw message.
      Parameters:
      message - raw byte array to be published

    • publish

      void publish(byte[] message, akka.javasdk.Metadata metadata)
      Simulate the publishing of a raw message.
      Parameters:
      message - raw byte array to be published
      metadata - associated with the message

    • publish

      void publish(EventingTestKit.Message<?> message)
      Simulate the publishing of a message.
      Parameters:
      message - to be published

    • publish

      <T> void publish(T message, String subject)
      Simulate the publishing of a message.
      Type Parameters:
      T -
      Parameters:
      message - to be published
      subject - to identify the entity

    • publish

      void publish(List<EventingTestKit.Message<?>> messages)
      Publish multiple messages.
      Parameters:
      messages - to be published

    • publishDelete

      void publishDelete(String subject)
      Publish a predefined delete message. Supported only in case of KeyValueEntity incoming message flow.
      Parameters:
      subject - to identify the entity