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(com.google.protobuf.ByteString message)

Simulate the publishing of a raw message.

void

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

Simulate the publishing of a raw message.

void

publish(List<EventingTestKit.Message<?>> messages)

Publish multiple messages.

void

publish(EventingTestKit.Message<?> message)

Simulate the publishing of a message.

<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, kalix.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 ValueEntity incoming message flow.
  
  Parameters:
  
  subject - to identify the entity