Examples of Sender

com.crashnote.core.send.Sender
The Dispatcher is responsible for transmitting the data from the client to the server by using Java's build-in capabilities around {@link HttpURLConnection}.
com.dragome.debugging.messages.Sender
com.google.android.gcm.server.Sender
Helper class to send messages to the GCM service using an API Key.
com.nokia.dempsy.messagetransport.Sender
A simple interface to send messages to a messaging server destination.
com.pegaa.uploader.sender.Sender
@author tayfun
com.stoof.IM.GUI.server.Sender
com.volantis.mps.bms.Sender

Interface defining details about the originator of a SendRequest. A Sender is merely a composite of SMTPAddress and MSISDN.

Warning: This is a facade provided for use by user code, not for implementation. User implementations of this interface are highly likely to be incompatible with future releases of the product at both binary and source levels.
@volantis-api-include-in InternalAPI
com.zeonfederated.mailclient.senders.Sender
common.Sender
communication.Sender
edu.pitt.dbmi.nlp.noble.util.Sender
edu.pitt.terminology.util.Sender
evolaris.framework.smsservices.datamodel.Sender
hudson.plugins.im.Sender
Represents a sender of a IM message @author Christoph Kutzinski
io.undertow.io.Sender
Sender interface that allows for callback based async IO. Note that all methods on this class are asynchronous, and may result in dispatch to an IO thread. After calling a method on this class you should not perform any more work on the current exchange until the callback is invoked. NOTE: implementers of this interface should be careful that they do not recursively call onComplete, which can lead to stack overflows if send is called many times. @author Stuart Douglas
net.sf.saxon.event.Sender
Sender is a helper class that sends events to a Receiver from any kind of Source object
net.sf.xbus.technical.Sender
Common interface for all Sender classes.
net.windwards.dnsfrontend.api.Sender
nexj.core.integration.Sender
Interface implemented by message client adapters. Used by clients to initiate message processing. The messages are passed in transfer objects, where the class name is the name of the message metadata object.
org.apache.hadoop.hdfs.protocol.datatransfer.Sender
Sender
org.apache.kafka.clients.producer.internals.Sender
The background thread that handles the sending of produce requests to the Kafka cluster. This thread makes metadata requests to renew its view of the cluster and then sends produce requests to the appropriate nodes.
org.apache.qpid.amqp_1_0.client.Sender
org.apache.qpid.proton.engine.Sender
Sender
org.apache.s4.base.Sender
Defines the exit point from the event processing layer to the communication layer. The implementation is responsible for serializing events and passing serialized data to the communication layer.
org.apache.s4.core.Sender
The {@link Sender} and its counterpart {@link Receiver} are the top level classes of the communication layer.
{@link Sender} is responsible for sending an event to a {@link ProcessingElement} instance using a hashKey.
Details on how the cluster is partitioned and how events are serialized and transmitted to its destination are hidden from the application developer.
org.apache.sandesha.server.Sender
This is the sender for Sandesha for both the client and the server sides. Starting of the Sender will be done either by the RMProvider or the SandeshaContext. The job of the sender is to keep on monitoring the SandeshaQueue and send any messages that are scheduled to be sent. @author Chamikar Jayalath @author Jaliya Ekanayake
org.apache.sandesha2.workers.Sender
This is responsible for sending and re-sending messages of Sandesha2. This represent a thread that keep running all the time. This keep looking at the Sender table to find out any entries that should be sent.
org.apache.servicemix.tck.Sender
A simple interface to allow polymorphic access to sending, test components. @version $Revision: 426415 $
org.collectd.protocol.Sender
Protocol independent Sender interface.
org.fenixedu.academic.domain.util.email.Sender
org.fluentd.logger.sender.Sender
org.jboss.narayana.blacktie.jatmibroker.core.transport.Sender
org.jresearch.gossip.beans.user.Sender
DOCUMENT ME! @author Dmitry Belov
org.mule.example.geomail.dao.Sender
org.pdf4j.saxon.event.Sender
Sender is a helper class that sends events to a Receiver from any kind of Source object
org.servicemix.examples.Sender
A simple interface to allow polymorphic access to sending, test components. @version $Revision: 567 $

Examples of org.apache.qpid.proton.engine.Sender

            }
        }


        public Sender create(Session session)
        {
            Sender sender = session.sender(_path);
            Target target = new Target();
            target.setAddress(_path);
            sender.setTarget(target);
            // the C implemenation does this:
            Source source = new Source();
            source.setAddress(_path);
            sender.setSource(source);
            if (getOutgoingWindow() > 0)
            {
                // use explicit settlement via dispositions (not pre-settled)
                sender.setSenderSettleMode(SenderSettleMode.UNSETTLED);
                sender.setReceiverSettleMode(ReceiverSettleMode.SECOND);  // desired
            }
            return sender;
        }

View Full Code Here

Examples of org.apache.qpid.proton.engine.Sender

            restoreMessage(m);
        }


        String ports = address.getPort() == null ? defaultPort(address.getScheme()) : address.getPort();
        int port = Integer.valueOf(ports);
        Sender sender = getLink(address.getHost(), port, new SenderFinder(address.getName()));
        pumpOut(m.getAddress(), sender);
    }

View Full Code Here

Examples of org.apache.s4.base.Sender


    public static void main(String[] args) {


        Injector injector = Guice.createInjector(new Module());
        MyApp myApp = injector.getInstance(MyApp.class);
        Sender sender = injector.getInstance(SenderImpl.class);
        ReceiverImpl receiver = injector.getInstance(ReceiverImpl.class);
        // myApp.setCommLayer(sender, receiver);
        myApp.init();
        myApp.start();

View Full Code Here

Examples of org.apache.s4.core.Sender


    public static void main(String[] args) {


        Injector injector = Guice.createInjector(new Module());
        MyApp myApp = injector.getInstance(MyApp.class);
        Sender sender = injector.getInstance(Sender.class);
        Receiver receiver = injector.getInstance(Receiver.class);
        // myApp.setCommLayer(sender, receiver);
        myApp.init();
        myApp.start();

View Full Code Here

Examples of org.apache.sandesha.server.Sender


    public static void initClient() throws AxisFault {
        if (log.isDebugEnabled()) {
            log.debug("STARTING SENDER FOR THE CLIENT .......");
        }
        sender = new Sender(storageManager);
        SimpleChain reqChain = null;
        SimpleChain resChain = null;
        try {
            reqChain = getRequestChain();
            resChain = getResponseChain();

View Full Code Here

Examples of org.apache.sandesha2.workers.Sender

    
    this.rMSBeanMgr = new InMemoryRMSBeanMgr (this, context);
    this.rMDBeanMgr = new InMemoryRMDBeanMgr (this, context);
    this.senderBeanMgr = new InMemorySenderBeanMgr (this, context);
    this.invokerBeanMgr = new InMemoryInvokerBeanMgr (this, context);
    this.sender = new Sender();
    if(inOrder) this.invoker = new Invoker();
    if(polling) this.pollingManager = new PollingManager();
  }

View Full Code Here

Examples of org.apache.sandesha2.workers.Sender

    return sortedList;
  }


  public static void startSenderForTheSequence(ConfigurationContext context, String sequenceID) {
    
    Sender sender = (Sender) context.getProperty(Sandesha2Constants.SENDER);
    
    if (sender!=null)
      sender.runSenderForTheSequence(context, sequenceID);
    else {
      sender = new Sender ();
      context.setProperty(Sandesha2Constants.SENDER,sender);
      sender.runSenderForTheSequence(context, sequenceID);
    }
  }

View Full Code Here

Examples of org.apache.sandesha2.workers.Sender

      sender.runSenderForTheSequence(context, sequenceID);
    }
  }


  private static void stopSenderForTheSequence(String sequenceID, ConfigurationContext context) {
    Sender sender = (Sender) context.getProperty(Sandesha2Constants.SENDER);
    
    if (sender!=null) {
      sender.stopSenderForTheSequence(sequenceID);
    }
  }

View Full Code Here

Examples of org.apache.sandesha2.workers.Sender

      sender.stopSenderForTheSequence(sequenceID);
    }
  }
  
  public static void stopSender(ConfigurationContext context) {
    Sender sender = (Sender) context.getProperty(Sandesha2Constants.SENDER);
    
    if (sender!=null) {
      sender.stopSending ();
    }
  }

View Full Code Here

Examples of org.apache.sandesha2.workers.Sender

    
    this.rMSBeanMgr = new InMemoryRMSBeanMgr (this, context);
    this.rMDBeanMgr = new InMemoryRMDBeanMgr (this, context);
    this.senderBeanMgr = new InMemorySenderBeanMgr (this, context);
    this.invokerBeanMgr = new InMemoryInvokerBeanMgr (this, context);
    this.sender = new Sender();
    if(inOrder) this.invoker = new Invoker();
    if(polling) this.pollingManager = new PollingManager();
  }

View Full Code Here

0 1 2 3 4 5 6 7

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.