Examples of LinkObject

Examples of org.apache.catalina.tribes.transport.bio.util.LinkObject

60
61
62
63
64
65
66
67
68
69
70
        return value;
    }

    @Override
    public boolean addToQueue(ChannelMessage msg, Member[] destination, InterceptorPayload payload) {
        final LinkObject obj = new LinkObject(msg,destination,payload);
        Runnable r = new Runnable() {
            @Override
            public void run() {
                sendAsyncData(obj);
            }
View Full Code Here

Examples of org.apache.catalina.tribes.transport.bio.util.LinkObject

161
162
163
164
165
166
167
168
169
170
171
        super.stop(svc);
    }
   
    public void run() {
        while ( run ) {
            LinkObject link = removeFromQueue();
            if ( link == null ) continue; //should not happen unless we exceed wait time
            while ( link != null && run ) {
                link = sendAsyncData(link);
            }//while
        }//while
View Full Code Here

Examples of org.apache.catalina.tribes.transport.bio.util.LinkObject

56
57
58
59
60
61
62
63
64
65
66
        currentSize.set(value);
        return value;
    }
   
    public boolean addToQueue(ChannelMessage msg, Member[] destination, InterceptorPayload payload) {
        final LinkObject obj = new LinkObject(msg,destination,payload);
        Runnable r = new Runnable() {
            public void run() {
                sendAsyncData(obj);
            }
        };
View Full Code Here

Examples of org.apache.catalina.tribes.transport.bio.util.LinkObject

169
170
171
172
173
174
175
176
177
178
179
    }

    @Override
    public void run() {
        while ( run ) {
            LinkObject link = removeFromQueue();
            if ( link == null ) continue; //should not happen unless we exceed wait time
            while ( link != null && run ) {
                link = sendAsyncData(link);
            }//while
        }//while
View Full Code Here

Examples of org.apache.catalina.tribes.transport.bio.util.LinkObject

62
63
64
65
66
67
68
69
70
71
72
        return value;
    }
   
    @Override
    public boolean addToQueue(ChannelMessage msg, Member[] destination, InterceptorPayload payload) {
        final LinkObject obj = new LinkObject(msg,destination,payload);
        Runnable r = new Runnable() {
            @Override
            public void run() {
                sendAsyncData(obj);
            }
View Full Code Here

Examples of org.apache.catalina.tribes.util.LinkObject

435
436
437
438
439
440
441
442
443
444
445
         * Get the objects from queue and send all mesages to the sender.
         * @see java.lang.Runnable#run()
         */
        public void run() {
            while (keepRunning) {
                LinkObject entry = getQueuedMessage();
                if (entry != null) {
                    pushQueuedMessages(entry);
                } else {
                    if (keepRunning) {
                        log.warn(sm.getString("AsyncSocketSender.queue.empty",
View Full Code Here

Examples of org.apache.catalina.tribes.util.LinkObject

456
457
458
459
460
461
462
463
464
465
         */
        protected LinkObject getQueuedMessage() {
            // get a link list of all queued objects
            if (log.isTraceEnabled())
                log.trace("Queuesize before=" + ((FastQueue) queue).getSize());
            LinkObject entry = queue.remove();
            if (log.isTraceEnabled())
                log.trace("Queuesize after=" + ((FastQueue) queue).getSize());
            return entry;
        }
View Full Code Here

Examples of org.fenixedu.academic.dto.LinkObject

95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
                final List<LinkObject> objects = (List<LinkObject>) object;
                final Iterator<LinkObject> iterator = objects.iterator();

                while (iterator.hasNext()) {
                    final LinkObject each = iterator.next();

                    final ObjectLinkRenderer linkRenderer = new ObjectLinkRenderer();

                    linkRenderer.setText(each.getLabel());
                    linkRenderer.setLinkFormat(getLinkFormat());
                    linkRenderer.setModuleRelative(isModuleRelative());
                    linkRenderer.setContextRelative(isContextRelative());

                    blockContainer.addChild(RenderKit.getInstance().renderUsing(linkRenderer, getContext(), each,
View Full Code Here

Examples of org.fenixedu.academic.dto.LinkObject

65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
    @Override
    public List<LinkObject> getFullPath() {
        final List<LinkObject> result = new ArrayList<LinkObject>();
        for (final Unit unit : searchFullPath()) {
            final LinkObject linkObject = new LinkObject();
            linkObject.setId(unit.getExternalId());
            linkObject.setLabel(unit.getName());
            linkObject.setMethod("viewUnit");
            result.add(linkObject);
        }

        final LinkObject linkObject = new LinkObject();
        linkObject.setId(getExternalCurricularCourse().getExternalId());
        linkObject.setLabel(getExternalCurricularCourse().getName());
        linkObject.setMethod("viewExternalCurricularCourse");
        result.add(linkObject);

        return result;
    }
View Full Code Here

Examples of org.fenixedu.academic.dto.LinkObject

55
56
57
58
59
60
61
62
63
64
65
66
67
    @Override
    public List<LinkObject> getFullPath() {
        final List<LinkObject> result = new ArrayList<LinkObject>();
        for (final Unit unit : searchFullPath()) {
            final LinkObject linkObject = new LinkObject();
            linkObject.setId(unit.getExternalId());
            linkObject.setLabel(unit.getName());
            linkObject.setMethod("viewUnit");
            result.add(linkObject);
        }
        return result;
    }
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.