Resolves checkstyle errors for remaining p (#1091)
* Reduces checkstyle errors in page-object * Reduces checkstyle errors in partial-response * Reduces checkstyle errors in pipeline * Reduces checkstyle errors in poison-pill * Reduces checkstyle errors in priority-queue * Reduces checkstyle errors in private-class-data * Reduces checkstyle errors in property * Reduces checkstyle errors in prototype * Reduces checkstyle errors in proxy
This commit is contained in:
committed by
Ilkka Seppälä
parent
1fdc650545
commit
271d7ae9bd
@ -30,16 +30,15 @@ package com.iluwatar.poison.pill;
|
||||
* Pill will stop reading messages from the queue. You must also ensure that the Poison Pill will be
|
||||
* the last message that will be read from the queue (if you have prioritized queue then this can be
|
||||
* tricky).
|
||||
* <p>
|
||||
* In simple cases the Poison Pill can be just a null-reference, but holding a unique separate
|
||||
*
|
||||
* <p>In simple cases the Poison Pill can be just a null-reference, but holding a unique separate
|
||||
* shared object-marker (with name "Poison" or "Poison Pill") is more clear and self describing.
|
||||
*
|
||||
*/
|
||||
public class App {
|
||||
|
||||
/**
|
||||
* Program entry point
|
||||
*
|
||||
* Program entry point.
|
||||
*
|
||||
* @param args command line args
|
||||
*/
|
||||
public static void main(String[] args) {
|
||||
|
@ -28,10 +28,10 @@ import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
/**
|
||||
* Class responsible for receiving and handling submitted to the queue messages
|
||||
* Class responsible for receiving and handling submitted to the queue messages.
|
||||
*/
|
||||
public class Consumer {
|
||||
|
||||
|
||||
private static final Logger LOGGER = LoggerFactory.getLogger(Consumer.class);
|
||||
|
||||
private final MqSubscribePoint queue;
|
||||
@ -43,7 +43,7 @@ public class Consumer {
|
||||
}
|
||||
|
||||
/**
|
||||
* Consume message
|
||||
* Consume message.
|
||||
*/
|
||||
public void consume() {
|
||||
while (true) {
|
||||
|
@ -65,7 +65,7 @@ public interface Message {
|
||||
};
|
||||
|
||||
/**
|
||||
* Enumeration of Type of Headers
|
||||
* Enumeration of Type of Headers.
|
||||
*/
|
||||
enum Headers {
|
||||
DATE, SENDER
|
||||
|
@ -24,7 +24,7 @@
|
||||
package com.iluwatar.poison.pill;
|
||||
|
||||
/**
|
||||
* Represents abstraction of channel (or pipe) that bounds {@link Producer} and {@link Consumer}
|
||||
* Represents abstraction of channel (or pipe) that bounds {@link Producer} and {@link Consumer}.
|
||||
*/
|
||||
public interface MessageQueue extends MqPublishPoint, MqSubscribePoint {
|
||||
|
||||
|
@ -24,7 +24,7 @@
|
||||
package com.iluwatar.poison.pill;
|
||||
|
||||
/**
|
||||
* Endpoint to publish {@link Message} to queue
|
||||
* Endpoint to publish {@link Message} to queue.
|
||||
*/
|
||||
public interface MqPublishPoint {
|
||||
|
||||
|
@ -24,7 +24,7 @@
|
||||
package com.iluwatar.poison.pill;
|
||||
|
||||
/**
|
||||
* Endpoint to retrieve {@link Message} from queue
|
||||
* Endpoint to retrieve {@link Message} from queue.
|
||||
*/
|
||||
public interface MqSubscribePoint {
|
||||
|
||||
|
@ -23,15 +23,14 @@
|
||||
|
||||
package com.iluwatar.poison.pill;
|
||||
|
||||
import java.util.Date;
|
||||
|
||||
import com.iluwatar.poison.pill.Message.Headers;
|
||||
import java.util.Date;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
/**
|
||||
* Class responsible for producing unit of work that can be expressed as message and submitted to
|
||||
* queue
|
||||
* queue.
|
||||
*/
|
||||
public class Producer {
|
||||
|
||||
@ -42,7 +41,7 @@ public class Producer {
|
||||
private boolean isStopped;
|
||||
|
||||
/**
|
||||
* Constructor
|
||||
* Constructor.
|
||||
*/
|
||||
public Producer(String name, MqPublishPoint queue) {
|
||||
this.name = name;
|
||||
@ -51,7 +50,7 @@ public class Producer {
|
||||
}
|
||||
|
||||
/**
|
||||
* Send message to queue
|
||||
* Send message to queue.
|
||||
*/
|
||||
public void send(String body) {
|
||||
if (isStopped) {
|
||||
@ -72,7 +71,7 @@ public class Producer {
|
||||
}
|
||||
|
||||
/**
|
||||
* Stop system by sending poison pill
|
||||
* Stop system by sending poison pill.
|
||||
*/
|
||||
public void stop() {
|
||||
isStopped = true;
|
||||
|
@ -28,7 +28,7 @@ import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
|
||||
/**
|
||||
* {@link Message} basic implementation
|
||||
* {@link Message} basic implementation.
|
||||
*/
|
||||
public class SimpleMessage implements Message {
|
||||
|
||||
|
@ -27,7 +27,7 @@ import java.util.concurrent.ArrayBlockingQueue;
|
||||
import java.util.concurrent.BlockingQueue;
|
||||
|
||||
/**
|
||||
* Bounded blocking queue wrapper
|
||||
* Bounded blocking queue wrapper.
|
||||
*/
|
||||
public class SimpleMessageQueue implements MessageQueue {
|
||||
|
||||
|
Reference in New Issue
Block a user