File tree Expand file tree Collapse file tree 12 files changed +29
-29
lines changed
main/java/com/iluwatar/publishsubscribe
test/java/com/iluwatar/publishsubscribe Expand file tree Collapse file tree 12 files changed +29
-29
lines changed Original file line number Diff line number Diff line change 1- package com .hungrydev399 .publishsubscribe ;
1+ package com .iluwatar .publishsubscribe ;
22
3- import com .hungrydev399 .publishsubscribe .jms .JmsUtil ;
4- import com .hungrydev399 .publishsubscribe .model .Message ;
5- import com .hungrydev399 .publishsubscribe .publisher .TopicPublisher ;
6- import com .hungrydev399 .publishsubscribe .subscriber .TopicSubscriber ;
7- import com .hungrydev399 .publishsubscribe .subscriber .SubscriberType ;
3+ import com .iluwatar .publishsubscribe .jms .JmsUtil ;
4+ import com .iluwatar .publishsubscribe .model .Message ;
5+ import com .iluwatar .publishsubscribe .publisher .TopicPublisher ;
6+ import com .iluwatar .publishsubscribe .subscriber .TopicSubscriber ;
7+ import com .iluwatar .publishsubscribe .subscriber .SubscriberType ;
88
99import java .util .ArrayList ;
1010import java .util .List ;
Original file line number Diff line number Diff line change 1- package com .hungrydev399 .publishsubscribe .jms ;
1+ package com .iluwatar .publishsubscribe .jms ;
22
33import org .apache .activemq .ActiveMQConnectionFactory ;
44import org .apache .activemq .broker .BrokerService ;
Original file line number Diff line number Diff line change 1- package com .hungrydev399 .publishsubscribe .model ;
1+ package com .iluwatar .publishsubscribe .model ;
22
33import java .io .Serializable ;
44
Original file line number Diff line number Diff line change 1- package com .hungrydev399 .publishsubscribe .publisher ;
1+ package com .iluwatar .publishsubscribe .publisher ;
22
33import javax .jms .DeliveryMode ;
44import javax .jms .JMSException ;
55import javax .jms .MessageProducer ;
66import javax .jms .Session ;
77import javax .jms .TextMessage ;
88import javax .jms .Topic ;
9- import com .hungrydev399 .publishsubscribe .jms .JmsUtil ;
10- import com .hungrydev399 .publishsubscribe .model .Message ;
9+ import com .iluwatar .publishsubscribe .jms .JmsUtil ;
10+ import com .iluwatar .publishsubscribe .model .Message ;
1111
1212/**
1313 * JMS topic publisher that supports persistent messages and message grouping
Original file line number Diff line number Diff line change 1- package com .hungrydev399 .publishsubscribe .subscriber ;
1+ package com .iluwatar .publishsubscribe .subscriber ;
22
33public enum SubscriberType {
44 NONDURABLE , // Regular non-durable subscriber
Original file line number Diff line number Diff line change 1- package com .hungrydev399 .publishsubscribe .subscriber ;
1+ package com .iluwatar .publishsubscribe .subscriber ;
22
33import javax .jms .Message ;
44import javax .jms .MessageConsumer ;
77import javax .jms .TextMessage ;
88import javax .jms .Topic ;
99import javax .jms .JMSException ;
10- import com .hungrydev399 .publishsubscribe .jms .JmsUtil ;
10+ import com .iluwatar .publishsubscribe .jms .JmsUtil ;
1111
1212/**
1313 * JMS topic subscriber that supports different subscription types:
Original file line number Diff line number Diff line change 1- package com .hungrydev399 .publishsubscribe ;
1+ package com .iluwatar .publishsubscribe ;
22
33import org .junit .jupiter .api .BeforeAll ;
44import org .junit .jupiter .api .AfterAll ;
5- import com .hungrydev399 .publishsubscribe .jms .JmsUtil ;
5+ import com .iluwatar .publishsubscribe .jms .JmsUtil ;
66
77/**
88 * Base class for JMS-related tests.
Original file line number Diff line number Diff line change 1- package com .hungrydev399 .publishsubscribe .jms ;
1+ package com .iluwatar .publishsubscribe .jms ;
22
33import static org .junit .jupiter .api .Assertions .*;
44import org .junit .jupiter .api .Test ;
Original file line number Diff line number Diff line change 1- package com .hungrydev399 .publishsubscribe .model ;
1+ package com .iluwatar .publishsubscribe .model ;
22
33import static org .junit .jupiter .api .Assertions .*;
44import org .junit .jupiter .api .Test ;
You can’t perform that action at this time.
0 commit comments