com.github.iamiddy.syncrest.asynchprocessor.service

Class SampleService

java.lang.Object

com.github.iamiddy.syncrest.asynchprocessor.service.SampleService

All Implemented Interfaces:

MessageProducer, Runnable

public class SampleService
extends Object
implements MessageProducer, Runnable

Author:

iddymagohe Created by iddymagohe on 1/9/16.

Constructor Summary

Constructors

Constructor and Description
SampleService(BlockingQueue<ResponseEvent> responseQueue, MessageConsumer consumer)

Method Summary

Modifier and Type	Method and Description
<R extends AbstractResponse> void	produceMessage(R request) Takes in a RequestEvent, reverse it's body and put the response in a blocking queue.
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

SampleService

public SampleService(BlockingQueue<ResponseEvent> responseQueue,
                     MessageConsumer consumer)

Method Detail

produceMessage

public <R extends AbstractResponse> void produceMessage(R request)

Takes in a RequestEvent, reverse it's body and put the response in a blocking queue.

Specified by:

produceMessage in interface MessageProducer

Type Parameters:

R - type

Parameters:

request - message to produce

run

public void run()

Specified by:

run in interface Runnable