Package org.omg.CosNotification

Examples of org.omg.CosNotification.Property

206
207
208
209
210
211
212
213
214
215
216
    {
        // setup test data
        TypedEventMessage _event = new TypedEventMessage();

        _event.setTypedEvent(CoffeeHelper.id(), DRINKING_COFFEE_ID, new Property[] {
                new Property("name", toAny("alphonse")), new Property("minutes", toAny(10)) });

        // setup mock
        MockCoffee _mockCoffee = new MockCoffee()
        {
            public void drinking_coffee(String name, int minutes)
View Full Code Here
252
253
254
255
256
257
258
259
260
261
262
263
        StructuredEventMessage _event = new StructuredEventMessage();

        StructuredEvent _data = getTestUtils().getEmptyStructuredEvent();

        _data.filterable_data = new Property[] {
                new Property("operation", toAny(DRINKING_COFFEE_ID)),
                new Property("name", toAny("alphonse")), new Property("minutes", toAny(10)) };

        _event.setStructuredEvent(_data, false, false);

        // setup mock
        MockCoffee _mockCoffee = new MockCoffee()
View Full Code Here
301
302
303
304
305
306
307
308
309
310
311
312
        AnyMessage _event = new AnyMessage();

        Any _any = getORB().create_any();

        PropertySeqHelper.insert(_any, new Property[] {
                new Property("operation", toAny(DRINKING_COFFEE_ID)),
                new Property("name", toAny("alphonse")), new Property("minutes", toAny(10)) });

        _event.setAny(_any);

        final CountDownLatch _hasReceived = new CountDownLatch(1);
       
View Full Code Here
99
100
101
102
103
104
105
106
107
108
109
        Any _any = getORB().create_any();

        TimeTHelper.insert(_any, _timeout);

        structuredEvent_.header.variable_header[0] = new Property(Timeout.value, _any);

        Message _event = messageFactory_.newMessage(structuredEvent_,
                                                    new IProxyConsumer() {
                                                        public boolean getStartTimeSupported() {
                                                            return true;
View Full Code Here
75
76
77
78
79
80
81
82
83
84
85
86
        assertEquals("%ANY", event.header.fixed_header.event_type.type_name);
    }
   
    public void testToTypedEvent() throws Exception
    {
        Property[] _props = new Property[] { new Property("operation", toAny("operationName")),
                new Property("p1", toAny("param1")), new Property("p2", toAny(10)) };

        objectUnderTest_.setAny(toAny(_props));

        Property[] ps = objectUnderTest_.toTypedEvent();
View Full Code Here
88
89
90
91
92
93
94
95
96
97
98
99
        assertEquals("operationName", ps[0].value.extract_string());
    }

    public void testNoTranslationPossible_1() throws Exception
    {
        Property[] _props = new Property[] { new Property("p1", toAny("param1")),
                new Property("p2", toAny(10)) };

        objectUnderTest_.setAny(toAny(_props));

        try
        {
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
        Any _startTimeAny = getClientORB().create_any();

        UtcTHelper.insert(_startTimeAny, Time.corbaTime(_time));

        structuredEvent_.header.variable_header[0] = new Property(StartTime.value, _startTimeAny);

        Any _timeoutAny = getClientORB().create_any();
        TimeTHelper.insert(_timeoutAny, timeout);

        structuredEvent_.header.variable_header[1] = new Property(Timeout.value, _timeoutAny);

        StructuredPushSender _sender = new StructuredPushSender(getClientORB());

        _sender.setStructuredEvent(structuredEvent_);
View Full Code Here
181
182
183
184
185
186
187
188
189
190
191
    {
        replayAll();

        final int interval = 1000;

        Property prop = newPacingInterval(interval);

        objectUnderTest_.set_qos(new Property[] { prop });

        verifyAll();
    }
View Full Code Here
198
199
200
201
202
203
204
205
206
207
208
        controlTaskProcessor_.setMatcher(TASKPROCESSOR_MATCHER);
        controlTaskProcessor_.setReturnValue(null);

        replayAll();

        Property prop = newPacingInterval(interval);

        objectUnderTest_.set_qos(new Property[] { prop });
        objectUnderTest_.connect_sequence_push_consumer(mockPushConsumer_);

        verifyAll();
View Full Code Here
216
217
218
219
220
221
222
223
224
225
226
        controlTaskProcessor_.setMatcher(TASKPROCESSOR_MATCHER);
        controlTaskProcessor_.setReturnValue(null);

        replayAll();

        Property prop = newPacingInterval(interval);

        objectUnderTest_.connect_sequence_push_consumer(mockPushConsumer_);
        objectUnderTest_.set_qos(new Property[] { prop });

        verifyAll();
View Full Code Here
TOP

Related Classes of org.omg.CosNotification.Property

  • demo.notification.whiteboard.ImageHandler
  • org.jacorb.notification.impl.DefaultMessageFactory
  • org.jacorb.notification.servant.AbstractProxySupplier
  • org.jacorb.notification.TypedEventMessage
  • org.jacorb.notification.util.AdminPropertySet
  • org.jacorb.notification.util.PropertySet
  • org.jacorb.notification.util.QoSPropertySet
  • org.jacorb.test.notification.AnyMessageTest
  • org.jacorb.test.notification.evaluate.DynamicEvaluatorTest
  • org.jacorb.test.notification.EventChannelTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.