List of sendEvent() Examples

Examples of sendEvent()

com.corundumstudio.socketio.SocketIOClient.sendEvent()
Send event with ack callback @param name - event name @param data - event data @param ackCallback - ack callback
com.hazelcast.client.ClientEndpoint.sendEvent()
com.sun.enterprise.admin.pluggable.RUExtensionFeature.sendEvent()
org.agilewiki.jactor.pubsub.publisher.Subscribe.sendEvent()
org.apache.cxf.event.EventProcessor.sendEvent()
Sends an event to the processor. @param e the event
org.apache.felix.eventadmin.impl.handler.EventHandlerProxy.sendEvent()
Send the event.
org.apache.ode.bpe.bped.EventDirector.sendEvent()
org.apache.oodt.cas.workflow.system.XmlRpcWorkflowManagerClient.sendEvent()
org.huihoo.workflow.impl.monitor.EventMonitorThread.sendEvent()
org.mule.DefaultMuleEventContext.sendEvent()
This will send an event via the configured outbound router on the service @param message the message to send @return the result of the send if any @throws org.mule.api.MuleException if there is no outbound endpoint configuredon the service or the events fails during dispatch
org.mule.api.MuleEventContext.sendEvent()
This will send an event via the configured outbound router on the service @param message the message to send @return the result of the send if any @throws MuleException if there is no outbound endpoint configured on theservice or the events fails during dispatch @deprecated
org.mule.api.service.Service.sendEvent()
Makes a synchronous event call to the service. This event will be consumed by the service and a result returned. @param event the event to consume @return a MuleMessage containing the resulting message and properties @throws MuleException if the event fails to be processed @deprecated
org.osgi.service.event.EventAdmin.sendEvent()
Initiate synchronous delivery of an event. This method does not return to the caller until delivery of the event is completed. @param event The event to send to all listeners which subscribe to thetopic of the event. @throws SecurityException If the caller does not have{@code TopicPermission[topic,PUBLISH]} for the topic specified inthe event.
org.papoose.event.EventAdminImpl.sendEvent()

Examples of org.mule.api.service.Service.sendEvent()

        if (logger.isDebugEnabled())
        {
            logger.debug("MuleClient sending event direct to: " + componentName + ". MuleEvent is: " + event);
        }


        MuleEvent resultEvent = service.sendEvent(event);
        MuleMessage result = resultEvent == null ? null : resultEvent.getMessage();
        if (logger.isDebugEnabled())
        {
            logger.debug("Result of MuleClient sendDirect is: "
                         + (result == null ? "null" : result.getPayload()));

View Full Code Here

Examples of org.mule.api.service.Service.sendEvent()

        if (logger.isDebugEnabled())
        {
            logger.debug("MuleClient sending event direct to: " + componentName + ". MuleEvent is: " + event);
        }


        MuleEvent resultEvent = service.sendEvent(event);
        MuleMessage result = resultEvent == null || VoidMuleEvent.getInstance().equals(resultEvent)
                                                                                                   ? null
                                                                                                   : resultEvent.getMessage();
        if (logger.isDebugEnabled())
        {

View Full Code Here

Examples of org.mule.api.service.Service.sendEvent()

        if (event.getFlowConstruct() instanceof Service)
        {
            Service service = (Service) event.getFlowConstruct();
            DefaultMuleEvent eventToSend = new DefaultMuleEvent(message,
                MessageExchangePattern.REQUEST_RESPONSE, service, session);
            MuleEvent event = service.sendEvent(eventToSend);
            return event == null || VoidMuleEvent.getInstance().equals(event) ? null : event.getMessage();
        }
        else
        {
            throw new MessagingException(

View Full Code Here

Examples of org.mule.api.service.Service.sendEvent()

            assertTrue(e.getCause() instanceof LifecycleException);
        }


        try
        {
            c.sendEvent(getTestEvent("hello", c));
            fail();
        }
        catch (MessagingException e)
        {
            assertTrue(e.getCause() instanceof LifecycleException);

View Full Code Here

Examples of org.mule.api.service.Service.sendEvent()

                    fail(e.getMessage());
                }
            }
        }).start();
        long t0 = System.currentTimeMillis();
        c.sendEvent(getTestEvent("hello"));
        long t1 = System.currentTimeMillis();
        assertTrue(t1 - t0 > 1000);
    }
}

View Full Code Here

Examples of org.mule.api.service.Service.sendEvent()

        else
        {
            Service service = muleContext.getRegistry().lookupService("component1");
            MuleEvent event = new DefaultMuleEvent(new DefaultMuleMessage("Test MuleEvent", muleContext),
                ((ServiceCompositeMessageSource) service.getMessageSource()).getEndpoints().get(0), service);
            service.sendEvent(event);
        }
    }


    public static class DummyComponent implements Callable
    {

View Full Code Here

Examples of org.osgi.service.event.EventAdmin.sendEvent()

                            sendEvent = false;
                        }
                    }


                    if ( sendEvent ) {
                        localEa.sendEvent(new org.osgi.service.event.Event(topic, new EventProperties(event)));
                    }
                }
            } catch (final Exception e) {
                logger.warn("processOsgiEventQueue: Unexpected problem processing event " + event, e);
            }

View Full Code Here

Examples of org.osgi.service.event.EventAdmin.sendEvent()

                        }
                    }
                }


                if ( sendEvent ) {
                    localEa.sendEvent(new org.osgi.service.event.Event(topic, new EventProperties(changes)));
                }
            }
        } catch (final Exception e) {
            logger.warn("sendOsgiEvent: Unexpected problem processing event " + topic + " at " + path + " with " + changes, e);
        }

View Full Code Here

Examples of org.osgi.service.event.EventAdmin.sendEvent()

    public void process(Exchange exchange) throws Exception {
        EventAdmin admin = (EventAdmin) this.tracker.getService();
        if (admin != null) {
            Event event = getEvent(exchange);
            if (endpoint.isSend()) {
                admin.sendEvent(event);
            } else {
                admin.postEvent(event);
            }
        } else {
            throw new CamelExchangeException("EventAdmin service not present", exchange);

View Full Code Here

Examples of org.osgi.service.event.EventAdmin.sendEvent()

            final Event jobEvent = this.getJobEvent(event, eventNode.getPath());
            eventNode.setProperty(EventHelper.NODE_PROPERTY_PROCESSOR, this.applicationId);
            eventNode.save();
            final EventAdmin localEA = this.eventAdmin;
            if ( localEA != null ) {
                localEA.sendEvent(jobEvent);
                // do not unlock if sending was successful
                unlock = false;
            } else {
                this.logger.error("Job event can't be sent as no event admin is available.");
            }

View Full Code Here

0 1 2 3 4 5

TOP

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.