Package org.jacorb.notification

Examples of org.jacorb.notification.StructuredEventMessage


            // received an Any wrapped inside a StructuredEvent
            // see Spec. 2-11
            return newMessage(structuredEvent.remainder_of_body, consumer);
        }

        StructuredEventMessage _mesg =
            (StructuredEventMessage) structuredEventMessagePool_.lendObject();

        _mesg.initReceiveTimestamp();

        _mesg.setFilterStage(consumer.getFirstStage());

        _mesg.setStructuredEvent(structuredEvent, consumer.getStartTimeSupported(), consumer
                .getStopTimeSupported());

        return _mesg.getHandle();
    }
View Full Code Here


        if (AnyMessage.TYPE_NAME.equals(_typeName))
        {
            return newMessage(structuredEvent.remainder_of_body);
        }

        StructuredEventMessage _mesg =
            (StructuredEventMessage) structuredEventMessagePool_.lendObject();

        _mesg.setStructuredEvent(structuredEvent, false, false);

        return _mesg.getHandle();
    }
View Full Code Here

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

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

        StructuredEventMessage mesg = new StructuredEventMessage(getORB());
        mesg.setStructuredEvent(structuredEvent_, true, true);
        final Message _event = mesg.getHandle();

        final HashSet _received = new HashSet();

        final Object lock = new Object();
View Full Code Here

            // received an Any wrapped inside a StructuredEvent
            // see Spec. 2-11
            return newMessage(structuredEvent.remainder_of_body, consumer);
        }

        StructuredEventMessage _mesg =
            (StructuredEventMessage) structuredEventMessagePool_.lendObject();

        _mesg.initReceiveTimestamp();

        _mesg.setFilterStage(consumer.getFirstStage());

        _mesg.setStructuredEvent(structuredEvent, consumer.getStartTimeSupported(), consumer
                .getStopTimeSupported());

        return _mesg.getHandle();
    }
View Full Code Here

        if (AnyMessage.TYPE_NAME.equals(_typeName))
        {
            return newMessage(structuredEvent.remainder_of_body);
        }

        StructuredEventMessage _mesg =
            (StructuredEventMessage) structuredEventMessagePool_.lendObject();

        _mesg.setStructuredEvent(structuredEvent, false, false);

        return _mesg.getHandle();
    }
View Full Code Here

            // received an Any wrapped inside a StructuredEvent
            // see Spec. 2-11
            return newMessage(structuredEvent.remainder_of_body, consumer);
        }

        StructuredEventMessage _mesg =
            (StructuredEventMessage) structuredEventMessagePool_.lendObject();

        _mesg.initReceiveTimestamp();

        _mesg.setFilterStage(consumer.getFirstStage());

        _mesg.setStructuredEvent(structuredEvent, consumer.getStartTimeSupported(), consumer
                .getStopTimeSupported());

        return _mesg.getHandle();
    }
View Full Code Here

        if (AnyMessage.TYPE_NAME.equals(_typeName))
        {
            return newMessage(structuredEvent.remainder_of_body);
        }

        StructuredEventMessage _mesg =
            (StructuredEventMessage) structuredEventMessagePool_.lendObject();

        _mesg.setStructuredEvent(structuredEvent, false, false);

        return _mesg.getHandle();
    }
View Full Code Here

    @Test
    public void testPushStructured() throws Exception
    {
        // setup test data
        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()
        {
            public void drinking_coffee(String name, int minutes)
            {
                super.drinking_coffee(name, minutes);

                assertEquals("alphonse", name);
                assertEquals(10, minutes);
            }
        };

        _mockCoffee.drinking_coffee_expect = 1;

        // setup and connect consumer
        final Coffee _coffee = _mockCoffee._this(getClientORB());

        MockTypedPushConsumer _mockConsumer = new MockTypedPushConsumer()
        {
            public org.omg.CORBA.Object get_typed_consumer()
            {
                return _coffee;
            }
        };

        TypedPushConsumer _consumer = _mockConsumer._this(getClientORB());

        proxyPushSupplier_.connect_typed_push_consumer(_consumer);

        // run test
        objectUnderTest_.getMessageConsumer().queueMessage(_event.getHandle());

        // verify results
        _mockCoffee.verify();
    }
View Full Code Here

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

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

        StructuredEventMessage mesg = new StructuredEventMessage(getORB());
        mesg.setStructuredEvent(structuredEvent_, true, true);
        final Message _event = mesg.getHandle();

        final HashSet _received = new HashSet();

        final Object lock = new Object();
View Full Code Here

    private StructuredEvent structuredEvent_;

    @Before
    public void setUp() throws Exception
    {
        objectUnderTest_ = new StructuredEventMessage(getORB());
        structuredEvent_ = getTestUtils().getEmptyStructuredEvent();
    }
View Full Code Here

TOP

Related Classes of org.jacorb.notification.StructuredEventMessage

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.