(String[] args)
| 21 | } |
| 22 | |
| 23 | public static void main(String[] args) throws Exception { |
| 24 | |
| 25 | System.out.println("Start Subscriber"); |
| 26 | boolean reliable = checkReliable(args); |
| 27 | |
| 28 | DomainParticipantFactory dpf = |
| 29 | TheParticipantFactory.WithArgs(new StringSeqHolder(args)); |
| 30 | if (dpf == null) { |
| 31 | System.err.println("ERROR: Domain Participant Factory not found"); |
| 32 | return; |
| 33 | } |
| 34 | DomainParticipant dp = dpf.create_participant(4, |
| 35 | PARTICIPANT_QOS_DEFAULT.get(), null, DEFAULT_STATUS_MASK.value); |
| 36 | if (dp == null) { |
| 37 | System.err.println("ERROR: Domain Participant creation failed"); |
| 38 | return; |
| 39 | } |
| 40 | |
| 41 | MessageTypeSupportImpl servant = new MessageTypeSupportImpl(); |
| 42 | if (servant.register_type(dp, "") != RETCODE_OK.value) { |
| 43 | System.err.println("ERROR: register_type failed"); |
| 44 | return; |
| 45 | } |
| 46 | Topic top = dp.create_topic("Movie Discussion List", |
| 47 | servant.get_type_name(), |
| 48 | TOPIC_QOS_DEFAULT.get(), |
| 49 | null, |
| 50 | DEFAULT_STATUS_MASK.value); |
| 51 | if (top == null) { |
| 52 | System.err.println("ERROR: Topic creation failed"); |
| 53 | return; |
| 54 | } |
| 55 | |
| 56 | Subscriber sub = dp.create_subscriber(SUBSCRIBER_QOS_DEFAULT.get(), |
| 57 | null, DEFAULT_STATUS_MASK.value); |
| 58 | if (sub == null) { |
| 59 | System.err.println("ERROR: Subscriber creation failed"); |
| 60 | return; |
| 61 | } |
| 62 | |
| 63 | // Use the default transport (do nothing) |
| 64 | |
| 65 | DataReaderQos dr_qos = new DataReaderQos(); |
| 66 | dr_qos.durability = new DurabilityQosPolicy(); |
| 67 | dr_qos.durability.kind = DurabilityQosPolicyKind.from_int(0); |
| 68 | dr_qos.deadline = new DeadlineQosPolicy(); |
| 69 | dr_qos.deadline.period = new Duration_t(); |
| 70 | dr_qos.latency_budget = new LatencyBudgetQosPolicy(); |
| 71 | dr_qos.latency_budget.duration = new Duration_t(); |
| 72 | dr_qos.liveliness = new LivelinessQosPolicy(); |
| 73 | dr_qos.liveliness.kind = LivelinessQosPolicyKind.from_int(0); |
| 74 | dr_qos.liveliness.lease_duration = new Duration_t(); |
| 75 | dr_qos.reliability = new ReliabilityQosPolicy(); |
| 76 | dr_qos.reliability.kind = ReliabilityQosPolicyKind.from_int(0); |
| 77 | dr_qos.reliability.max_blocking_time = new Duration_t(); |
| 78 | dr_qos.destination_order = new DestinationOrderQosPolicy(); |
| 79 | dr_qos.destination_order.kind = DestinationOrderQosPolicyKind.from_int(0); |
| 80 | dr_qos.history = new HistoryQosPolicy(); |
nothing calls this directly
no test coverage detected