public class ContractVerifierStreamMessaging<T> extends Object implements ContractVerifierMessaging<T,org.springframework.messaging.Message<T>>
Constructor and Description |
---|
ContractVerifierStreamMessaging(org.springframework.context.ApplicationContext context,
ContractVerifierMessageBuilder<T,org.springframework.messaging.Message<T>> builder) |
Modifier and Type | Method and Description |
---|---|
ContractVerifierMessage<T,org.springframework.messaging.Message<T>> |
create(org.springframework.messaging.Message<T> message) |
ContractVerifierMessage<T,org.springframework.messaging.Message<T>> |
create(T t,
Map<String,Object> headers) |
ContractVerifierMessage<T,org.springframework.messaging.Message<T>> |
receiveMessage(String destination) |
ContractVerifierMessage<T,org.springframework.messaging.Message<T>> |
receiveMessage(String destination,
long timeout,
TimeUnit timeUnit) |
void |
send(ContractVerifierMessage<T,org.springframework.messaging.Message<T>> message,
String destination) |
void |
send(T payload,
Map<String,Object> headers,
String destination) |
@Autowired public ContractVerifierStreamMessaging(org.springframework.context.ApplicationContext context, ContractVerifierMessageBuilder<T,org.springframework.messaging.Message<T>> builder)
public void send(T payload, Map<String,Object> headers, String destination)
send
in interface ContractVerifierMessaging<T,org.springframework.messaging.Message<T>>
public void send(ContractVerifierMessage<T,org.springframework.messaging.Message<T>> message, String destination)
send
in interface ContractVerifierMessaging<T,org.springframework.messaging.Message<T>>
public ContractVerifierMessage<T,org.springframework.messaging.Message<T>> receiveMessage(String destination, long timeout, TimeUnit timeUnit)
receiveMessage
in interface ContractVerifierMessaging<T,org.springframework.messaging.Message<T>>
public ContractVerifierMessage<T,org.springframework.messaging.Message<T>> receiveMessage(String destination)
receiveMessage
in interface ContractVerifierMessaging<T,org.springframework.messaging.Message<T>>
public ContractVerifierMessage<T,org.springframework.messaging.Message<T>> create(T t, Map<String,Object> headers)
create
in interface ContractVerifierMessageBuilder<T,org.springframework.messaging.Message<T>>
public ContractVerifierMessage<T,org.springframework.messaging.Message<T>> create(org.springframework.messaging.Message<T> message)
create
in interface ContractVerifierMessageBuilder<T,org.springframework.messaging.Message<T>>
Copyright © 2016 Spring. All rights reserved.