Re: [Dev] [Stratos2] Why we expose CartridgeAgentService ONLY in https transport?

[Damitha Kumarage]

Since S2 deployment is internally behind a firewall(This would be the case
most of the time IMO) I think default endpoint should be http. It should be
configurable by devops otherwise.

Damitha


On Sun, Apr 7, 2013 at 1:26 AM, Nirmal Fernando  wrote:

> Hi,
>
> $Subject? In a S2 deployment, where the infrastructure is maintained
> internally (and external access is protected by a firewall) , I don't find
> any reason for exposing this only in 'https' mode. Rather, IMO we should
> let the dev-ops (who configure the S2 env.) decide what endpoint they want
> to use.
>
> WDYT?
>
> --
>
> Thanks & regards,
> Nirmal
>
> Software Engineer- Platform Technologies Team, WSO2 Inc.
> Mobile: +94715779733
> Blog: http://nirmalfdo.blogspot.com/
>
> 
>



-- 
__
Damitha Kumarage
Senior Technical Lead; WSO2 Inc.
Oxygenating the Web Service Platform
http://www.wso2.com/
blog:
http://damithakumarage.wordpress.com/
__
___
Dev mailing list
Dev@wso2.org
http://wso2.org/cgi-bin/mailman/listinfo/dev

Re: [Dev] Message processor's max.delivery.attempts not considered

[Prabath Abeysekera]

Hi,

Please ignore my previous reply.

I've gone through the attached configurations and thought there was nothing
wrong in them except for setting the property FORCE_SC_ACCEPTED within the
fault sequence, as it wouldn't make any sense to define it in the fault
sequence.

However, I've tried a sample scenario with the provided configurations (ESB
v4.6.0) and observed that the message processor honors the
max.delivery.attempts parameter value without any issue. Therefore, I'm
guessing this might have to do something with the ESB version you're using
as we'd come across a similar problem with one of the earlier ESB versions
[1].


[1] https://wso2.org/jira/browse/ESBJAVA-1688


Cheers,
Prabath


On Wed, Apr 10, 2013 at 7:36 AM, Prabath Abeysekera wrote:

> Try setting,  within your proxy
> configuration before you dump the message into the store.
>
> IMO, it would be fundamentally inappropriate to let the ESB wait for a
> response of a message dispatched out of the combination of message
> store/processor as those two entities have been designed primarily to
> support asynchronous messaging.
>
> Hope this helps!
>
>
> Cheers,
> Prabath
>
> On Tue, Apr 9, 2013 at 4:40 PM, Shelan Perera  wrote:
>
>> Hi,
>>
>> Could you please remove > scope="axis2" type="STRING"/> from your proxy and try again?. ESB should be
>> waiting for a response  and hence can be
>> retrying.
>>
>> Thanks
>>
>>
>> On Tue, Apr 9, 2013 at 11:42 AM, Mohammad Benslimne <
>> mohammad.benslim...@gmail.com> wrote:
>>
>>> Please, any help ?
>>>
>>>
>>> On 3 April 2013 11:41, Mohammad Benslimne >> > wrote:
>>>
 Hi folks,

 I am implementing a dead letter channel using message store and
 processor as described in attached files, and I would like to stop retry
 after max.delivery.attempts and send a timeout fault
 But the value specified in max.delivery.attempts is not considered and
 message processor keeps retrying indefinitely.
 Is it a wrong configuration of my receipt or a bug in your side?

 Thanks in advance for your help!

 Regards,

 --


 Mohammad

>>>
>>>
>>>
>>> --
>>>
>>>
>>> Mohammad
>>>
>>> ___
>>> Dev mailing list
>>> Dev@wso2.org
>>> http://wso2.org/cgi-bin/mailman/listinfo/dev
>>>
>>>
>>
>>
>> --
>> *Shelan Perera*
>>
>> Software Engineer
>> **
>> *WSO2, Inc. : wso2.com*
>> lean.enterprise.middleware.
>>
>> *Home Page*  :   shelan.org
>> *Blog* :   blog.shelan.org
>> *Linked-i*n  :   http://www.linkedin.com/pub/shelan-perera/a/194/465
>> *Twitter* :https://twitter.com/#!/shelan
>>
>> *Mobile*  : +94 772 604 402
>>
>>
>> ___
>> Dev mailing list
>> Dev@wso2.org
>> http://wso2.org/cgi-bin/mailman/listinfo/dev
>>
>>
>
>
> --
> Prabath Abeysekara
> Email: praba...@wso2.com 
> Mobile: +94774171471
>
> 
>



-- 
Prabath Abeysekara
Email: praba...@wso2.com 
Mobile: +94774171471


___
Dev mailing list
Dev@wso2.org
http://wso2.org/cgi-bin/mailman/listinfo/dev

[Dev] error: java.io.IOException: Decompression of response failed.

[Jorge Infante Osorio]

Hi all. Sorry for post this question here and not in Stack overflow, but we
have problems with the internet access in this days, as soon as I have
internet I repost the question with the answer in SO.

I have this scenario:

I consume some information from a data service and another information from
another data service and I want to merge this two information in a unique
response.

In this test I don´t use the data services, I use mock services in SOAPUI
and both mock services work fine separately .

The data I want to merge, an example:

Data service 1 response:

http://www.w3.org/2003/05/soap-envelope";
xmlns:obt="http://informatizacion.uci.cu/servicios/assets/ObtenerPersonas";>
   
   
  
 
 
T123654
yanet
soraine
perez
F
920125848
matanzas
varadero
facultad5
false
 
  
   



Data service 2 response:
http://www.w3.org/2003/05/soap-envelope";
xmlns:preg="http://pregrado.uci.cu";>
   
   
  
 
 
1
jorge
infante
osorio
M
1221122112211221
holguin
gibara
CDAE
true
 
 
gero et
sonoras imperio
quae divum incedo
verrantque per
auras
per auras
circum claustra
nimborum in
foedere certo
profundum quippe ferant
false
 
  
   



So I build this proxy service:

http://ws.apache.org/ns/synapse"; name="PersonaPoC"
transports="https,http" statistics="disable" trace="disable"
startOnLoad="true">
   
   
   


With this sequences:

Name: obtener_estudiantes.

http://ws.apache.org/ns/synapse";>
   
  
 http://pregrado.uci.cu"/>
  
   
   
  
 http://destrono:8088/mockPregradoWSSOAP12Binding/"/>
  
   


Name: guardar_Estudiantes.

http://ws.apache.org/ns/synapse";>
   
  
  
   
   
  
 http://informatizacion.uci.cu/servicios/assets/ObtenerPersonas"/>
  
   
   
   
  
 http://destrono:/mockAssetsSOAP12Binding"/>
  
   



At this point I see this error in the ESB when execute the service:

This is a log of the message send to the second service,
mockAssetsSOAP12Binding. I don´t know why appear this namespace:
xmlns:preg=http://pregrado.uci.cu  in the request because I don´t used it in
the payloadfactory mediator.

[2013-04-10 20:17:17,303]  INFO - LogMediator To:
http://www.w3.org/2005/08/addressing/anonymous, WSAction: , SOAPAction: ,
MessageID: urn:uuid:26b0c552-d8e6-4285-8814-84c595dae544, Direction:
response, Envelope: 

http://www.w3.org/2003/05/soap-envelope";
xmlns:preg="http://pregrado.uci.cu";>
  
 http://informatizacion.uci.cu/servicios/assets/ObtenerPersonas"/>
  


The error:

[2013-04-10 19:49:30,472] ERROR - RelayUtils Error while building
Passthrough stream
org.apache.axiom.soap.SOAPProcessingException: Transport level information
does not match with SOAP Message namespace URI
at
org.apache.axis2.builder.BuilderUtil.validateSOAPVersion(BuilderUtil.java:77
4)
at
org.apache.axis2.builder.SOAPBuilder.processDocument(SOAPBuilder.java:58)
at
org.apache.synapse.transport.passthru.util.DeferredMessageBuilder.getDocumen
t(DeferredMessageBuilder.java:146)
at
org.apache.synapse.transport.passthru.util.RelayUtils.builldMessage(RelayUti
ls.java:150)
at
org.apache.synapse.transport.passthru.util.RelayUtils.buildMessage(RelayUtil
s.java:91)
at
org.apache.synapse.mediators.AbstractListMediator.mediate(AbstractListMediat
or.java:62)
at
org.apache.synapse.mediators.base.SequenceMediator.mediate(SequenceMediator.
java:114)
at
org.apache.synapse.core.axis2.Axis2SynapseEnvironment.injectMessage(Axis2Syn
apseEnvironment.java:223)
at
org.apache.synapse.core.axis2.SynapseCallbackReceiver.handleMessage(SynapseC
allbackReceiver.java:443)
at
org.apache.synapse.core.axis2.SynapseCallbackReceiver.receive(SynapseCallbac
kReceiver.java:166)
at org.apache.axis2.engine.AxisEngine.receive(AxisEngine.java:180)
at
org.apache.synapse.transport.passthru.ClientWorker.run(ClientWorker.java:217
)
at
org.apache.axis2.transport.base.threads.NativeWorkerPool$1.run(NativeWorkerP
ool.java:172)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:11
10)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:6
03)
at java.lang.Thread.run(Thread.java:722)

when I used the data services in AS 5.1.0 I saw this error:
org.apache.axiom.soap.SOAPProcessingException: First Element must contain
the local name, Envelope , but found faultstring


If I put the TCPMon I can see this message exchange:

Incoming message:
POST /mockAssetsSOAP12Binding HTTP/1.1
Content

Re: [Dev] [CEP] Siddhi's current limitations - "Siddhi will not support joining multiple streams." ?

[Sriskandarajah Suhothayan]

Thanks for notifying I have edited to
"Siddhi does not support joining three or more stream in a single query."

Suho

On Tue, Apr 9, 2013 at 9:33 PM, Nirmal Fernando  wrote:
> http://docs.wso2.org/wiki/display/CEP210/Current+Limitations
>
> AFAIU the wording here is wrong. Siddhi in fact can join two streams, hence
> you can't say it doesn't support joining multiple streams.
>
> --
>
> Thanks & regards,
> Nirmal
>
> Software Engineer- Platform Technologies Team, WSO2 Inc.
> Mobile: +94715779733
> Blog: http://nirmalfdo.blogspot.com/
>



-- 
S. Suhothayan
Software Engineer,
Member, Management Committee - Data Technologies Team,
WSO2 Inc. http://wso2.com
lean . enterprise . middleware

cell: (+94) 779 756 757
blog: http://suhothayan.blogspot.com/
twitter: http://twitter.com/suhothayan
linked-in: http://lk.linkedin.com/in/suhothayan
___
Dev mailing list
Dev@wso2.org
http://wso2.org/cgi-bin/mailman/listinfo/dev

[Dev] AND query bug in CEP 2.0.0

[Yangjin Wu]

 Hi all,

   I am testing the LogicPattern(AND) in CEP using the following query:

frome1 = Stream2[price > 70] and
e2 = Stream2[symbol == "IBM"] ->
e3 = Stream1[price > 70]
insert into OutStream
e1.symbol as symbol1, e2.price as symbol2, e3.price as symbol3

and send events like this:
stream2.send(new Object[]{"GOOG", 72.7f, 100});
Thread.sleep(500);
stream1.send(new Object[]{"WSO2", 55.6f, 100});
Thread.sleep(500);
when the second event sends,then the projector sends outstream event,but 
actually the logic "and" condition doesn't match.

Is it a bug?

Thanks in advance for your help!

Regards,

below is the test function code:


@Test
public void testQuery4() throws InterruptedException {
log.info("testPatternLogic4 - OUT 1");

SiddhiManager siddhiManager = new SiddhiManager();


siddhiManager.defineStream(QueryFactory.createStreamDefinition().name("Stream1").attribute("symbol",
 Attribute.Type.STRING).attribute("price", 
Attribute.Type.FLOAT).attribute("volume", Attribute.Type.INT));

siddhiManager.defineStream(QueryFactory.createStreamDefinition().name("Stream2").attribute("symbol",
 Attribute.Type.STRING).attribute("price", 
Attribute.Type.FLOAT).attribute("volume", Attribute.Type.INT));

Query query = QueryFactory.createQuery();
query.from(
QueryFactory.patternStream(
Pattern.followedBy(
Pattern.logical(
QueryFactory.inputStream("e1", 
"Stream2").filter(

Condition.compare(Expression.variable("price"),
  
Condition.Operator.GREATER_THAN,
  
Expression.value(70))),
LogicalElement.Type.AND,
QueryFactory.inputStream("e2", 
"Stream2").filter(

Condition.compare(Expression.variable("symbol"),
  
Condition.Operator.EQUAL,
  
Expression.value("IBM",
QueryFactory.inputStream("e3", 
"Stream1").filter(

Condition.compare(Expression.variable("price"),
  
Condition.Operator.GREATER_THAN,
  
Expression.value(20));

query.insertInto("OutStream");
query.project(
QueryFactory.outputProjector().
project("symbol1", Expression.variable("e1", "symbol")).
project("symbol2", Expression.variable("e2", "price")).
project("symbol3", Expression.variable("e3", "price"))

);


String queryReference= siddhiManager.addQuery(query);
siddhiManager.addCallback(queryReference, new QueryCallback() {
@Override
public void receive(long timeStamp, Event[] inEvents, Event[] 
removeEvents) {
EventPrinter.print(timeStamp, inEvents, removeEvents);
Assert.assertArrayEquals(new Object[]{"WSO2", 72.7f, 4.7f}, 
inEvents[0].getData());
eventCount++;
eventArrived = true;
}
});
InputHandler stream1 = siddhiManager.getInputHandler("Stream1");
InputHandler stream2 = siddhiManager.getInputHandler("Stream2");
stream2.send(new Object[]{"GOOG", 72.7f, 100});
Thread.sleep(500);
stream1.send(new Object[]{"WSO2", 55.6f, 100});
Thread.sleep(500);
stream2.send(new Object[]{"IBM", 4.7f, 100});
Thread.sleep(500);
stream1.send(new Object[]{"WSO2", 55.6f, 100});
Thread.sleep(500);

siddhiManager.shutdown();

Assert.assertEquals("Number of success events", 1, eventCount);
Assert.assertEquals("Event arrived", true, eventArrived);

}

);

___
Dev mailing list
Dev@wso2.org
http://wso2.org/cgi-bin/mailman/listinfo/dev