camel-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Adam Brewster (JIRA)" <j...@apache.org>
Subject [jira] Commented: (CAMEL-1962) Seda producer throws if queue is full
Date Sun, 30 Aug 2009 17:27:16 GMT

    [ https://issues.apache.org/activemq/browse/CAMEL-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=53895#action_53895
] 

Adam Brewster commented on CAMEL-1962:
--------------------------------------

It looks like that won't work because SedaProducer overrides the process method to call add
anyway
{code}
queue.add(copy);
// lets see if we can get the task done before the timeout
boolean done = latch.await(timeout, TimeUnit.MILLISECONDS);
if (!done) {
     exchange.setException(new ExchangeTimedOutException(exchange, timeout));
}
{code}

and

{code}
// no wait, eg its a InOnly then just add to queue and return
queue.add(copy);
{code}

----

The second block can be replaced easily with 

{code}
// no wait, eg its a InOnly then just add to queue and return
queue.put(copy);
{code}

but I'm not sure of the best way to handle this when the caller wants a response.  Maybe it's
as simple as
{code}
if (!queue.offer(copy, timeout, TimeUnit.MILLISECONDS)) {
     exchange.setException(new QueueFullException(exchange));
} else if (!latch.await(timeout, TimeUnit.MILLISECONDS)) {
     exchange.setException(new ExchangeTimedOutException(exchange, timeout));
}
{code}
This, however, allows the possibility of waiting twice as long as the timeout (if the the
queue accepts the exchange just before the timeout expires latch.await will still wait the
full timeout).

Another possibility is
{code}
if (!queue.offer(copy)) {
     exchange.setException(new QueueFullException(exchange));
} else if (!latch.await(timeout, TimeUnit.MILLISECONDS)) {
     exchange.setException(new ExchangeTimedOutException(exchange, timeout));
}
{code}
But it will be confusing when the queue-full behavior depends on the ExchangePatern (InOut
drops extra packets, InOnly blocks)

> Seda producer throws if queue is full
> -------------------------------------
>
>                 Key: CAMEL-1962
>                 URL: https://issues.apache.org/activemq/browse/CAMEL-1962
>             Project: Apache Camel
>          Issue Type: Bug
>          Components: camel-core
>    Affects Versions: 1.6.1, 2.0.0
>         Environment: Java SE 5
>            Reporter: Adam Brewster
>         Attachments: 0001-seda-don-t-throw-IllegalStateException.patch
>
>   Original Estimate: 30 minutes
>  Remaining Estimate: 30 minutes
>
> The LinkedBlockingQueue used by the SedaComponent supports a couple of different ways
to insert an object into the queue.
>  - Collection.add adds the element immediately if possible or throws an IllegalStateException
if the queue is full
>  - BlockingQueue.offer adds the element immediately if possible or returns false if the
queue is full
>  - BlockingQueue.put waits if necessary and adds the element when space is available
> SedaProducer extends CollectionProducer which holds a reference to a collection, so it
has to use the add method specified by the Collection interface.
> I suggest that either of the BlockingQueue methods would be superior.

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


Mime
View raw message