io.eventuate.tram.spring.cloudcontractsupport

Class EventuateTramMessageVerifier

java.lang.Object

io.eventuate.tram.spring.cloudcontractsupport.EventuateTramMessageVerifier

All Implemented Interfaces:

org.springframework.cloud.contract.verifier.messaging.MessageVerifier<Message>

public class EventuateTramMessageVerifier
extends java.lang.Object
implements org.springframework.cloud.contract.verifier.messaging.MessageVerifier<Message>

Constructor Summary

Constructors

Constructor and Description
EventuateTramMessageVerifier()

Method Summary

Modifier and Type	Method and Description
Message	receive(java.lang.String destination)
Message	receive(java.lang.String destination, long timeout, java.util.concurrent.TimeUnit timeUnit)
void	send(Message message, java.lang.String destination)
<T> void	send(T payload, java.util.Map<java.lang.String,java.lang.Object> headers, java.lang.String destination)
void	subscribe()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EventuateTramMessageVerifier

public EventuateTramMessageVerifier()

Method Detail

send

public void send(Message message,
                 java.lang.String destination)

Specified by:

send in interface org.springframework.cloud.contract.verifier.messaging.MessageVerifier<Message>

subscribe

@PostConstruct
public void subscribe()

send

public <T> void send(T payload,
                     java.util.Map<java.lang.String,java.lang.Object> headers,
                     java.lang.String destination)

Specified by:

send in interface org.springframework.cloud.contract.verifier.messaging.MessageVerifier<Message>

receive

public Message receive(java.lang.String destination,
                       long timeout,
                       java.util.concurrent.TimeUnit timeUnit)

Specified by:

receive in interface org.springframework.cloud.contract.verifier.messaging.MessageVerifier<Message>

receive

public Message receive(java.lang.String destination)

Specified by:

receive in interface org.springframework.cloud.contract.verifier.messaging.MessageVerifier<Message>