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(EventingTestKit.Message<?> message)

Simulate the publishing of a message.

void

publish(com.google.protobuf.ByteString message)

Simulate the publishing of a raw message.

void

publish(com.google.protobuf.ByteString message, akka.javasdk.Metadata metadata)

Simulate the publishing of a raw message.

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
  
  void publish(com.google.protobuf.ByteString message)
  
  Simulate the publishing of a raw message.
  
  Parameters:
  
  message - raw bytestring to be published
- publish
  
  void publish(com.google.protobuf.ByteString message, akka.javasdk.Metadata metadata)
  
  Simulate the publishing of a raw message.
  
  Parameters:
  
  message - raw bytestring 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