Package org.apache.activemq.broker.region

Examples of org.apache.activemq.broker.region.MessageReference

66
67
68
69
70
71
72
73
74
75
76
77
        List copy = buffer.getMessages(sub);
        if( !copy.isEmpty() ) {
            MessageEvaluationContext msgContext = context.getMessageEvaluationContext();
            try {
                for (Iterator iter = copy.iterator(); iter.hasNext();) {
                    MessageReference node = (MessageReference) iter.next();
                    msgContext.setDestination(node.getRegionDestination().getActiveMQDestination());
                    msgContext.setMessageReference(node);
                    if (sub.matches(node, msgContext) ) {
                        sub.add(node);
                    }
                }
View Full Code Here
58
59
60
61
62
63
64
65
66
67
        int delta = node.getMessageHardRef().getSize();
        synchronized (lock) {
            list.add(node);
            size += delta;
            while (size > maximumSize) {
                MessageReference evicted = (MessageReference) list.removeFirst();
                size -= evicted.getMessageHardRef().getSize();
            }
        }
    }
View Full Code Here
73
74
75
76
77
78
79
80
81
82
83
84
85
86
    public Message[] browse(ActiveMQDestination destination) {
        List result = new ArrayList();
        DestinationFilter filter=DestinationFilter.parseFilter(destination);
        synchronized(lock){
            for (Iterator i = list.iterator(); i.hasNext();){
                MessageReference ref = (MessageReference)i.next();
                Message msg;
                try{
                    msg=ref.getMessage();
                    if (filter.matches(msg.getDestination())){
                        result.add(msg);
                    }
                }catch(IOException e){
                   log.error("Failed to get Message from MessageReference: " + ref,e);
View Full Code Here
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
        return true;
    }

    public void recover(ConnectionContext context, Topic topic, Subscription sub) throws Exception {
        // Re-dispatch the last message seen.
        MessageReference node = lastImage;
        if( node != null ){
            MessageEvaluationContext msgContext = context.getMessageEvaluationContext();
            try {
                msgContext.setDestination(node.getRegionDestination().getActiveMQDestination());
                msgContext.setMessageReference(node);                       
                if (sub.matches(node, msgContext)) {
                    sub.add(node);
                }
            } finally {
View Full Code Here
35
36
37
38
39
40
41
42
43
44
45
46
    public MessageReference[] evictMessages(LinkedList messages) throws IOException {
        byte lowestPriority = Byte.MAX_VALUE;
        int pivot = 0;
        Iterator iter = messages.iterator();
        for (int i = 0; iter.hasNext(); i++) {
            MessageReference reference = (MessageReference) iter.next();
            byte priority = reference.getMessage().getPriority();
            if (priority < lowestPriority) {
                lowestPriority = priority;
                pivot = i;
            }
        }
View Full Code Here
43
44
45
46
47
48
49
50
51
52
        return true;
    }

    public void recover(ConnectionContext context, Topic topic, SubscriptionRecovery sub) throws Exception {
        // Re-dispatch the last message seen.
        MessageReference node = lastImage;
        if (node != null) {
            sub.addRecoveredMessage(context, node);
        }
    }
View Full Code Here
64
65
66
67
68
69
70
71
72
73
74
        if (messages[t] == null) {
            return;
        }
        // Keep dispatching until t hit's tail again.
        do {
            MessageReference node = messages[t];
            sub.addRecoveredMessage(context, node);
            t++;
            if (t >= messages.length) {
                t = 0;
            }
View Full Code Here
102
103
104
105
106
107
108
109
110
111
112
113
        if (messages[t] == null) {
            t = 0;
        }
        if (messages[t] != null) {
            do {
                MessageReference ref = messages[t];
                Message message = ref.getMessage();
                if (filter.matches(message.getDestination())) {
                    result.add(message);
                }
                t++;
                if (t >= messages.length) {
View Full Code Here
82
83
84
85
86
87
88
89
90
91
        // Re-dispatch the messages from the buffer.
        ArrayList<TimestampWrapper> copy = new ArrayList<TimestampWrapper>(buffer);
        if (!copy.isEmpty()) {
            for (Iterator<TimestampWrapper> iter = copy.iterator(); iter.hasNext();) {
                TimestampWrapper timestampWrapper = iter.next();
                MessageReference message = timestampWrapper.message;
                sub.addRecoveredMessage(context, message);
            }
        }
    }
View Full Code Here
128
129
130
131
132
133
134
135
136
137
138
139
        List<Message> result = new ArrayList<Message>();
        ArrayList<TimestampWrapper> copy = new ArrayList<TimestampWrapper>(buffer);
        DestinationFilter filter = DestinationFilter.parseFilter(destination);
        for (Iterator<TimestampWrapper> iter = copy.iterator(); iter.hasNext();) {
            TimestampWrapper timestampWrapper = iter.next();
            MessageReference ref = timestampWrapper.message;
            Message message = ref.getMessage();
            if (filter.matches(message.getDestination())) {
                result.add(message);
            }
        }
        return result.toArray(new Message[result.size()]);
View Full Code Here
TOP

Related Classes of org.apache.activemq.broker.region.MessageReference

  • org.apache.activemq.broker.region.cursors.AbstractStoreCursor
  • org.apache.activemq.broker.region.cursors.FilePendingMessageCursor
  • org.apache.activemq.broker.region.cursors.FilePendingMessageCursorTest
  • org.apache.activemq.broker.region.cursors.OrderedPendingList
  • org.apache.activemq.broker.region.cursors.StoreDurableSubscriberCursor
  • org.apache.activemq.broker.region.cursors.StoreQueueCursor
  • org.apache.activemq.broker.region.cursors.StoreQueueCursorNoDuplicateTest
  • org.apache.activemq.broker.region.cursors.StoreQueueCursorOrderTest
  • org.apache.activemq.broker.region.cursors.VMPendingMessageCursor
  • org.apache.activemq.broker.region.policy.FixedCountSubscriptionRecoveryPolicy
    • 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.