Package org.omg.CosNotification

Examples of org.omg.CosNotification.Property

125
126
127
128
129
130
131
132
133
134
135
        if (filterableHeader_ == null)
        {
            filterableHeader_ = new Property[parameters_.length + 1];
            Any _operationAny = sORB.create_any();
            _operationAny.insert_string(operationName_);
            filterableHeader_[0] = new Property(OPERATION_NAME, _operationAny);

            for (int x = 0; x < parameters_.length; ++x)
            {
                filterableHeader_[1 + x] = parameters_[x];
            }
View Full Code Here
175
176
177
178
179
180
181
182
183
184
185
            _eventType.type_name = operationName_;

            Any _eventTypeAny = sORB.create_any();
            EventTypeHelper.insert(_eventTypeAny, _eventType);

            typedEvent_[0] = new Property(EVENT_TYPE, _eventTypeAny);

            for (int x = 0; x < parameters_.length; ++x)
            {
                typedEvent_[1 + x] = parameters_[x];
            }
View Full Code Here
56
57
58
59
60
61
62
63
64
65
66
67
        structuredEvent_ = getTestUtils().getEmptyStructuredEvent();
    }

    public void testToTypedEvent() throws Exception
    {
        Property[] _props1 = new Property[] { new Property("operation", toAny("operationName")),
                new Property("p1", toAny("param1")), new Property("p2", toAny(20)) };

        structuredEvent_.filterable_data = _props1;

        objectUnderTest_.setStructuredEvent(structuredEvent_, false, false);
View Full Code Here
71
72
73
74
75
76
77
78
79
80
81
82
        assertEquals("operationName", _props2[0].value.extract_string());
    }

    public void testToTypedEvent_FailedConversion()
    {
        Property[] _props = new Property[] { new Property("p1", toAny("param1")),
                new Property("p2", toAny(20)) };

        structuredEvent_.filterable_data = _props;

        objectUnderTest_.setStructuredEvent(structuredEvent_, false, false);
View Full Code Here
96
97
98
99
100
101
102
103
104
105
106
        Any _any = getClientORB().create_any();
        UtcTHelper.insert(_any, Time.corbaTime(_time));

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

        objectUnderTest_.setStructuredEvent(structuredEvent_, true, false);
       
        assertFalse(objectUnderTest_.hasStopTime());
    }
View Full Code Here
125
126
127
128
129
130
131
132
133
134
135
        Any _startTimeAny = getORB().create_any();
        UtcT _startTime = Time.corbaTime(_now);
        UtcTHelper.insert(_startTimeAny, _startTime);

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

        Message _event = messageFactory_.newMessage(structuredEvent_, proxyConsumerMock_);

        assertTrue(_event.hasStartTime());
        assertEquals(_now.getTime(), _event.getStartTime());
View Full Code Here
153
154
155
156
157
158
159
160
161
162
163
        final Date _startTime = new Date(System.currentTimeMillis() + offset);

        Any _startTimeAny = getORB().create_any();
        UtcTHelper.insert(_startTimeAny, Time.corbaTime(_startTime));

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

        final Message _event = messageFactory_.newMessage(structuredEvent_, proxyConsumerMock_);

        final CountDownLatch _latch = new CountDownLatch(1);
View Full Code Here
515
516
517
518
519
520
521
522
523
524
525
            event_.header.fixed_header.event_name = "";
            event_.header.variable_header = new Property[1];
            Any _any = orb_.create_any();
            _any.insert_long(control_.getWorkgroupId());
            event_.header.variable_header[0] = new Property(WORKGROUP_ID, _any);
            event_.filterable_data = new Property[0];
            event_.remainder_of_body = orb_.create_any();
        }
        return event_;
    }
View Full Code Here
515
516
517
518
519
520
521
522
523
524
525
            event_.header.fixed_header.event_name = "";
            event_.header.variable_header = new Property[1];
            Any _any = orb_.create_any();
            _any.insert_long(control_.getWorkgroupId());
            event_.header.variable_header[0] = new Property(WORKGROUP_ID, _any);
            event_.filterable_data = new Property[0];
            event_.remainder_of_body = orb_.create_any();
        }
        return event_;
    }
View Full Code Here
252
253
254
255
256
257
258
259
260
261
262
263
        StructuredEventMessage _event = new StructuredEventMessage(getORB());

        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
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.