Examples of Consumer


Examples of au.com.dius.pact.model.Consumer

                                      Map<String, String> requestHeaders,
                                      String query,
                                      String requestBody,
                                      Map<String, Object> requestMatchers) {
            this.requestMatchers = requestMatchers;
            this.consumer = new Consumer(consumerName);
            this.provider = new Provider(providerName);

            this.state = state;

            this.description = description;
View Full Code Here

Examples of com.alibaba.dubbo.registry.common.domain.Consumer

            for (Provider p : providers) {
                serviceUrls.put(p.getUrl(), p.getParameters());
            }
        }
        if(StringUtils.isNotEmpty(consumerid)) {
            Consumer consumer = consumerService.findConsumer(Long.valueOf(consumerid));
            if(null == consumer) {
                context.put("message", getMessage("NoSuchRecord"));
            }
            Map<String, String> result = RouteUtils.previewRoute(consumer.getService(), consumer.getAddress(), consumer.getParameters(), serviceUrls,
                    route, null, null);
            context.put("route", route);
            context.put("consumer", consumer);
            context.put("result", result);
        }
        else {
            String address = (String)context.get("address");
            String service = (String)context.get("service");
           
            Map<String, String> result = RouteUtils.previewRoute(service, address, null, serviceUrls,
                    route, null, null);
            context.put("route", route);
           
            Consumer consumer = new Consumer();
            consumer.setService(service);
            consumer.setAddress(address);
            context.put("consumer", consumer);
            context.put("result", result);
        }
       
    }
View Full Code Here

Examples of com.aliyun.openservices.ons.api.Consumer

public class ConsumerClient {
    public static void main(String[] args) {
        Properties properties = new Properties();
        properties.put(PropertyKeyConst.ConsumerId, "ConsumerId1");
        properties.put(PropertyKeyConst.MessageModel, PropertyValueConst.BROADCASTING);
        Consumer consumer = ONSFactory.createConsumer(properties);

        consumer.subscribe("TopicTestONS", "*", new MessageListener() {

            @Override
            public Action consume(Message message, ConsumeContext context) {
                System.out.println(message);
                return Action.CommitMessage;
            }
        });

        consumer.start();
    }
View Full Code Here

Examples of com.consol.citrus.messaging.Consumer

        if (log.isDebugEnabled()) {
            log.debug("Setting message selector: '" + selectorString + "'");
        }

        Endpoint messageEndpoint = getOrCreateEndpoint(context);
        Consumer consumer = messageEndpoint.createConsumer();
        if (consumer instanceof SelectiveConsumer) {
            if (receiveTimeout > 0) {
                return ((SelectiveConsumer) messageEndpoint.createConsumer()).receive(
                        context.replaceDynamicContentInString(selectorString),
                        context, receiveTimeout);
            } else {
                return ((SelectiveConsumer) messageEndpoint.createConsumer()).receive(
                        context.replaceDynamicContentInString(selectorString),
                        context, messageEndpoint.getEndpointConfiguration().getTimeout());
            }
        } else {
            log.warn(String.format("Unable to receive selective with consumer implementation: '%s'", consumer.getClass()));
            return receive(context);
        }


    }
View Full Code Here

Examples of com.packtpub.java7.concurrency.chapter2.recipe2.task.Consumer

    // Creates a Producer and a Thread to run it
    Producer producer=new Producer(storage);
    Thread thread1=new Thread(producer);

    // Creates a Consumer and a Thread to run it
    Consumer consumer=new Consumer(storage);
    Thread thread2=new Thread(consumer);
   
    // Starts the thread
    thread2.start();
    thread1.start();
View Full Code Here

Examples of com.packtpub.java7.concurrency.chapter2.recipe6.task.Consumer

    Thread threadProducer=new Thread(producer,"Producer");
   
    /**
     * Creates three consumers and threads to run them
     */
    Consumer consumers[]=new Consumer[3];
    Thread threadConsumers[]=new Thread[3];
   
    for (int i=0; i<3; i++){
      consumers[i]=new Consumer(buffer);
      threadConsumers[i]=new Thread(consumers[i],"Consumer "+i);
    }
   
    /**
     * Strats the producer and the consumers
View Full Code Here

Examples of com.packtpub.java7.concurrency.chapter3.recipe7.task.Consumer

    Exchanger<List<String>> exchanger=new Exchanger<>();
   
    // Creates the producer
    Producer producer=new Producer(buffer1, exchanger);
    // Creates the consumer
    Consumer consumer=new Consumer(buffer2, exchanger);
   
    // Creates and starts the threads
    Thread threadProducer=new Thread(producer);
    Thread threadConsumer=new Thread(consumer);
   
View Full Code Here

Examples of com.packtpub.java7.concurrency.chapter6.recipe03.task.Consumer

   
    /*
     * Launch 100 Consumer tasks
     */
    for (int i=0; i<THREADS; i++){
      Consumer consumer=new Consumer("Consumer "+i,buffer);
      consumerThreads[i]=new Thread(consumer);
      consumerThreads[i].start();
    }
   
    /*
 
View Full Code Here

Examples of com.packtpub.java7.concurrency.chapter7.recipe09.task.Consumer

    }

    /*
     * Create and launch the consumer
     */
    Consumer consumer=new Consumer(buffer);
    Thread consumerThread=new Thread(consumer);
    consumerThread.start();

    /*
     * Write in the console the actual consumer count
View Full Code Here

Examples of com.pinterest.secor.consumer.Consumer

                + " consumer threads");
        System.out.println("Rate limit:" + config.getMessagesPerSecond());
        LinkedList<Consumer> consumers = new LinkedList<Consumer>();
        long startMillis = System.currentTimeMillis();
        for (int i = 0; i < config.getConsumerThreads(); ++i) {
            Consumer consumer = new Consumer(config);
            consumer.setUncaughtExceptionHandler(handler);
            consumers.add(consumer);
            consumer.start();
        }

        while (true) {
            for (Consumer consumer : consumers) {
                for (String topic : topics) {
                    for (int i = 0; i < num_partitions; i++) {
                        OffsetTracker offsetTracker = consumer
                                .getOffsetTracker();
                        long val = (offsetTracker == null) ? -1
                                : offsetTracker
                                        .getLastSeenOffset(new TopicPartition(
                                                topic, i)) + 1;
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.