hi all,
I want to wrapper a high level library using activemq to
implement a request-reply service. the user of this library have 2
kind of api --synchronized blocking and asynchronized callback.
usage1:
MainThread:
RequestResponseWrapper wrapper=new RequestResponseWrapper();
wrapper.setMaxConcurrentThrad(10);
wrapper.setTimeout(10000);
Thread[] workers=new Thread[N];
for(int i=0;i<N;i++){
workers[i]=new WorkerThread(wrapper);
workers[i].start();
}
for(int i=0;i<N;i++){
workers[i].join();
}
WorkerThread:
while(true){
String req=...;
String response=wrapper.request(req);
System.out.println(response);
}
usage2:
MainThread:
RequestResponseWrapper wrapper=new RequestResponseWrapper();
wrapper.setMaxConcurrentThrad(10);
wrapper.setTimeout(10000);
CallBack callBack=new CallBack();
wrapper.setCallBack(callBack);
while(true){
String req=...;
wrapper.asyncRequest(req);
}
CallBack:
onSuccess(String request,String response){
}
onFail(String request, int failReason){
}
Any suggestion for me? I need implement both the java and c++ library.
