#1673

Committed 06 Sep 2015 05:33PM UTC coverage: 84.947% (-0.7%) from 85.644%

Build # #1673

Build Type

push

Committed by Markus

Commit Message

Removed the Markdown Plus custom heading id's

Because the renderer of github doesnt support markdown plus...

Run Details

3070 of 3614 relevant lines covered (84.95%)

0.85 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

23.53

/poison-pill/src/main/java/com/iluwatar/poison/pill/Consumer.java

package com.iluwatar.poison.pill;

import com.iluwatar.poison.pill.Message.Headers;

/**
 * Class responsible for receiving and handling submitted to the queue messages
 */
public class Consumer {

        private final MQSubscribePoint queue;
        private final String name;

        public Consumer(String name, MQSubscribePoint queue) {
                this.name = name;
                this.queue = queue;
        }

        public void consume() {
                while (true) {
                        Message msg;
                        try {
                                msg = queue.take();
                                if (msg == Message.POISON_PILL) {
                                        System.out.println(String.format("Consumer %s receive request to terminate.", name));
                                        break;
                                }
                        } catch (InterruptedException e) {
                                // allow thread to exit
                                System.err.println(e);
                                return;
                        }

                        String sender = msg.getHeader(Headers.SENDER);
                        String body = msg.getBody();
                        System.out.println(String.format("Message [%s] from [%s] received by [%s]", body, sender, name));
                }
        }
}

1	package com.iluwatar.poison.pill;
2
3	import com.iluwatar.poison.pill.Message.Headers;
4
5	/**
6	* Class responsible for receiving and handling submitted to the queue messages
7	*/
8	public class Consumer {
9
10	private final MQSubscribePoint queue;
11	private final String name;
12
13	public Consumer(String name, MQSubscribePoint queue) {	1✔
14	this.name = name;	1✔
15	this.queue = queue;	1✔
16	}	1✔
17
18	public void consume() {
19	while (true) {
20	Message msg;
21	try {
22	msg = queue.take();	×
23	if (msg == Message.POISON_PILL) {	×
24	System.out.println(String.format("Consumer %s receive request to terminate.", name));	×
25	break;	×
26	}
27	} catch (InterruptedException e) {	×
28	// allow thread to exit
29	System.err.println(e);	×
30	return;	×
31	}	×
32
33	String sender = msg.getHeader(Headers.SENDER);	×
34	String body = msg.getBody();	×
35	System.out.println(String.format("Message [%s] from [%s] received by [%s]", body, sender, name));	×
36	}	×
37	}	×
38	}

iluwatar / java-design-patterns / #1673

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous