Package com.betfair.cougar.core.api.ev

Examples of com.betfair.cougar.core.api.ev.ExecutionObserver

850
851
852
853
854
855
856
857
858
859
860
    @Override
    public Long bulkCaller(RequestContext ctx, Integer cycles, String logLevel, TimeConstraints timeConstraints) throws SimpleException {
        ctx.setRequestLogExtension(new BaselineLogExtension(cycles, null, null));
        final CountDownLatch latch = new CountDownLatch(cycles);
        ExecutionObserver obs = new ExecutionObserver() {
            @Override
            public void onResult(ExecutionResult executionResult) {
                latch.countDown();
            }
        };
View Full Code Here
1804
1805
1806
1807
1808
1809
1810
1811
1812
1813
1814
1815
1816
1817
    public void emitLongEvent(RequestContext ctx, String eventNamespace, Long longArg, TimeConstraints timeConstraints) throws SimpleException {
        ctx.setRequestLogExtension(new BaselineLogExtension(eventNamespace, longArg, null));
        ctx.getLocation().getRemoteAddr();
        ctx.getLocation().getResolvedAddresses();
        if (longEventNamespacedExecutionObserver.containsKey(eventNamespace)) {
            ExecutionObserver observer = longEventNamespacedExecutionObserver.get(eventNamespace);
            LongEvent longEvent = new LongEvent();
            longEvent.setLongArg(longArg);
            observer.onResult(new ExecutionResult(longEvent));
        } else {
            throw new SimpleException(ResponseCode.BadRequest,  SimpleExceptionErrorCodeEnum.GENERIC,
                    "Unknown event namespace: "+ eventNamespace);
        }
    }
View Full Code Here
1820
1821
1822
1823
1824
1825
1826
1827
1828
1829
1830
        List<EventTransportIdentity> transportIdentities = ctx.getIdentity().getIdentities(EventTransportIdentity.class);
        return transportIdentities.get(0);
    }

    private ExecutionObserver observer(final String eventName, final List events) {
        return new ExecutionObserver() {
            @Override
            public void onResult(ExecutionResult executionResult) {
                switch (executionResult.getResultType()) {
                    case Fault:
                        break;
View Full Code Here
847
848
849
850
851
852
853
854
855
856
857
    @Override
    public Long bulkCaller(RequestContext ctx, Integer cycles, String logLevel, TimeConstraints timeConstraints) throws SimpleException {
        ctx.setRequestLogExtension(new BaselineLogExtension(cycles, null, null));
        final CountDownLatch latch = new CountDownLatch(cycles);
        ExecutionObserver obs = new ExecutionObserver() {
            @Override
            public void onResult(ExecutionResult executionResult) {
                latch.countDown();
            }
        };
View Full Code Here
1812
1813
1814
1815
1816
1817
1818
1819
1820
1821
1822
1823
1824
1825
    public void emitLongEvent(RequestContext ctx, String eventNamespace, Long longArg, TimeConstraints timeConstraints) throws SimpleException {
        ctx.setRequestLogExtension(new BaselineLogExtension(eventNamespace, longArg, null));
        ctx.getLocation().getRemoteAddr();
        ctx.getLocation().getResolvedAddresses();
        if (longEventNamespacedExecutionObserver.containsKey(eventNamespace)) {
            ExecutionObserver observer = longEventNamespacedExecutionObserver.get(eventNamespace);
            LongEvent longEvent = new LongEvent();
            longEvent.setLongArg(longArg);
            observer.onResult(new ExecutionResult(longEvent));
        } else {
            throw new SimpleException(ResponseCode.BadRequest,  SimpleExceptionErrorCodeEnum.GENERIC,
                    "Unknown event namespace: "+ eventNamespace);
        }
    }
View Full Code Here
1828
1829
1830
1831
1832
1833
1834
1835
1836
1837
1838
        List<EventTransportIdentity> transportIdentities = ctx.getIdentity().getIdentities(EventTransportIdentity.class);
        return transportIdentities.get(0);
    }

    private ExecutionObserver observer(final String eventName, final List events) {
        return new ExecutionObserver() {
            @Override
            public void onResult(ExecutionResult executionResult) {
                switch (executionResult.getResultType()) {
                    case Fault:
                        break;
View Full Code Here
61
62
63
64
65
66
67
68
69
70
71
72
73
    }

    public void notifyObservers(int state) {
        synchronized (executionObservers) {
            for (WeakReference<ExecutionObserver> ref : executionObservers) {
                ExecutionObserver obs = ref.get();
                if (obs != null) {
                    obs.onResult(new ExecutionResult(new CougarFrameworkException(ServerFaultCode.JMSTransportCommunicationFailure, "Connection to ActiveMQ has been lost")));
                }
            }
            executionObservers = new HashSet<WeakReference<ExecutionObserver>>();
        }
    }
View Full Code Here
74
75
76
77
78
79
80
81
82
83
84
    private void cleanupObserverList() {
        List<WeakReference> deadList = new ArrayList<WeakReference>();
        synchronized (executionObservers) {
            for (WeakReference<ExecutionObserver> ref : executionObservers) {
                ExecutionObserver obs = ref.get();
                if (obs == null) {
                    deadList.add(ref);
                }
            }
            executionObservers.removeAll(deadList);
View Full Code Here
TOP

Related Classes of com.betfair.cougar.core.api.ev.ExecutionObserver

  • com.betfair.cougar.baseline.BaselineServiceImpl
  • com.betfair.cougar.transport.activemq.ActiveMQSubscriptionEventListener
  • com.betfair.platform.application.EventConsumer
  • com.betfair.platform.TestClient
    • 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.