You can subscribe to this list here.
2006 |
Jan
|
Feb
|
Mar
|
Apr
|
May
|
Jun
|
Jul
|
Aug
(141) |
Sep
(184) |
Oct
(159) |
Nov
(77) |
Dec
(114) |
---|---|---|---|---|---|---|---|---|---|---|---|---|
2007 |
Jan
(212) |
Feb
(302) |
Mar
(323) |
Apr
(360) |
May
(302) |
Jun
(392) |
Jul
(299) |
Aug
(858) |
Sep
(499) |
Oct
(489) |
Nov
(324) |
Dec
(438) |
2008 |
Jan
(449) |
Feb
(388) |
Mar
(811) |
Apr
(583) |
May
(949) |
Jun
(1431) |
Jul
(943) |
Aug
(527) |
Sep
(576) |
Oct
(440) |
Nov
(1046) |
Dec
(658) |
2009 |
Jan
(259) |
Feb
(192) |
Mar
(495) |
Apr
(2322) |
May
(2023) |
Jun
(1387) |
Jul
(722) |
Aug
(771) |
Sep
(167) |
Oct
(142) |
Nov
(384) |
Dec
(884) |
2010 |
Jan
(344) |
Feb
(82) |
Mar
(248) |
Apr
(341) |
May
(389) |
Jun
(289) |
Jul
(19) |
Aug
(478) |
Sep
(274) |
Oct
(431) |
Nov
(322) |
Dec
(207) |
2011 |
Jan
(125) |
Feb
|
Mar
|
Apr
|
May
|
Jun
|
Jul
|
Aug
|
Sep
|
Oct
|
Nov
|
Dec
|
From: Joseph I. <jos...@us...> - 2011-01-22 11:00:22
|
Update of /cvsroot/tolven/assemblerGlassFish3/log4j In directory sfp-cvsdas-2.v30.ch3.sourceforge.com:/tmp/cvs-serv20829/log4j Log Message: Directory /cvsroot/tolven/assemblerGlassFish3/log4j added to the repository --> Using per-directory sticky tag `V2' |
From: John C. <jc...@us...> - 2011-01-18 16:16:54
|
Update of /cvsroot/tolven/CVSROOT In directory sfp-cvsdas-2.v30.ch3.sourceforge.com:/tmp/cvs-serv4071 Modified Files: avail Log Message: Disable V2 commits - see new SVN repository. Index: avail =================================================================== RCS file: /cvsroot/tolven/CVSROOT/avail,v retrieving revision 1.142 retrieving revision 1.143 diff -C2 -d -r1.142 -r1.143 *** avail 14 Jan 2011 20:14:12 -0000 1.142 --- avail 18 Jan 2011 16:16:46 -0000 1.143 *************** *** 1,4 **** unavail avail|jchurin - avail|joseph_isaac||V2 --- 1,3 ---- |
From: Joseph I. <jos...@us...> - 2011-01-18 10:04:41
|
Update of /cvsroot/tolven/tolvenEJB/conf In directory sfp-cvsdas-2.v30.ch3.sourceforge.com:/tmp/cvs-serv25131/conf Modified Files: Tag: V2 sun-ejb-jar.xml Log Message: Added EndpointPoolResizeCount=1 since the default of 8 causes the EndpointPoolMaxSize to be ineffective as Glassfish resizes past it. Index: sun-ejb-jar.xml =================================================================== RCS file: /cvsroot/tolven/tolvenEJB/conf/sun-ejb-jar.xml,v retrieving revision 1.4.8.6 retrieving revision 1.4.8.7 diff -C2 -d -r1.4.8.6 -r1.4.8.7 *** sun-ejb-jar.xml 4 Nov 2010 10:24:52 -0000 1.4.8.6 --- sun-ejb-jar.xml 18 Jan 2011 10:04:33 -0000 1.4.8.7 *************** *** 29,32 **** --- 29,36 ---- </activation-config-property> <activation-config-property> + <activation-config-property-name>EndpointPoolResizeCount</activation-config-property-name> + <activation-config-property-value>1</activation-config-property-value> + </activation-config-property> + <activation-config-property> <activation-config-property-name>SendUndeliverableMsgsToDMQ </activation-config-property-name> <activation-config-property-value>true</activation-config-property-value> *************** *** 61,64 **** --- 65,72 ---- </activation-config-property> <activation-config-property> + <activation-config-property-name>EndpointPoolResizeCount</activation-config-property-name> + <activation-config-property-value>1</activation-config-property-value> + </activation-config-property> + <activation-config-property> <activation-config-property-name>SendUndeliverableMsgsToDMQ</activation-config-property-name> <activation-config-property-value>true</activation-config-property-value> *************** *** 93,96 **** --- 101,108 ---- </activation-config-property> <activation-config-property> + <activation-config-property-name>EndpointPoolResizeCount</activation-config-property-name> + <activation-config-property-value>1</activation-config-property-value> + </activation-config-property> + <activation-config-property> <activation-config-property-name>SendUndeliverableMsgsToDMQ </activation-config-property-name> <activation-config-property-value>true</activation-config-property-value> |
From: Joseph I. <jos...@us...> - 2011-01-17 10:13:51
|
Update of /cvsroot/tolven/tolvenEJB/src/org/tolven/doc In directory sfp-cvsdas-2.v30.ch3.sourceforge.com:/tmp/cvs-serv26148/src/org/tolven/doc Modified Files: Tag: V2 TolvenMessageSchedulerLocal.java RuleQueueLocal.java Log Message: When multiple messages are queued, they are all queued using one connection Index: RuleQueueLocal.java =================================================================== RCS file: /cvsroot/tolven/tolvenEJB/src/org/tolven/doc/Attic/RuleQueueLocal.java,v retrieving revision 1.1.2.1 retrieving revision 1.1.2.2 diff -C2 -d -r1.1.2.1 -r1.1.2.2 *** RuleQueueLocal.java 29 Apr 2010 01:47:00 -0000 1.1.2.1 --- RuleQueueLocal.java 17 Jan 2011 10:13:43 -0000 1.1.2.2 *************** *** 15,18 **** --- 15,19 ---- import java.io.Serializable; + import java.util.List; import java.util.Map; *************** *** 21,27 **** --- 22,54 ---- public String getQueueName(); + /** + * Queue a payload + * @param payload + */ public void send(Serializable payload); + /** + * Queue payloads + * One connection is used to send the List of payloads + * @param payloads + */ + public void send(List<Serializable> payloads); + + /** + * Queue a payload along with its JMS properties + * A separate connection is used for each payload + * @param payload + * @param properties + */ public void send(Serializable payload, Map<String, Object> properties); + /** + * Queue a list of payloads along with their JMS properties. Each payload must have a corresponding + * properties map, even if that map is empty + * One connection is used to send the List of payloads + * @param payloads + * @param listOfProperties + */ + public void send(List<Serializable> payloads, List<Map<String, Object>> listOfProperties); + } Index: TolvenMessageSchedulerLocal.java =================================================================== RCS file: /cvsroot/tolven/tolvenEJB/src/org/tolven/doc/TolvenMessageSchedulerLocal.java,v retrieving revision 1.3.2.1 retrieving revision 1.3.2.2 diff -C2 -d -r1.3.2.1 -r1.3.2.2 *** TolvenMessageSchedulerLocal.java 24 Dec 2010 01:13:32 -0000 1.3.2.1 --- TolvenMessageSchedulerLocal.java 17 Jan 2011 10:13:43 -0000 1.3.2.2 *************** *** 18,21 **** --- 18,22 ---- import java.util.Date; + import java.util.List; import java.util.Map; *************** *** 45,56 **** public TolvenMessage findTolvenMessage(long id); public void queue(TolvenMessage tm); ! public void schedule(TolvenMessage tm, Date queueOnDate); public void queue(TolvenMessage tm, Map<String, Object> properties); ! public void schedule(TolvenMessage tm, Date queueOnDate, Map<String, Object> properties); ! public TolvenMessage unwrapTolvenMessage(ObjectMessage objectMessage); --- 46,98 ---- public TolvenMessage findTolvenMessage(long id); + /** + * Queue a TolvenMessage. + * @param tm + */ public void queue(TolvenMessage tm); ! /** ! * Queue a list of TolvenMessages ! * One connection is used to send the List of TolvenMessages ! * @param tms ! */ ! public void queue(List<TolvenMessage> tms); + /** + * Queue a TolvenMessage along with JMS properties + * A separate connection is used for each payload + * @param tm + * @param properties + */ public void queue(TolvenMessage tm, Map<String, Object> properties); + + /** + * Queue a list of TolvenMessages along with their JMS properties. Each payload must have a corresponding + * properties map, even if that map is empty + * A separate connection is used for each payload + * @param tm + * @param properties + */ + public void queue(List<TolvenMessage> tm, List<Map<String, Object>> properties); ! /** ! * Schedule a TolvenMessage to be queued on queueOnDate ! * @param tm ! * @param queueOnDate ! */ ! public void schedule(TolvenMessage tm, Date queueOnDate); ! ! /** ! * Schedule a TolvenMessage to be queued on queueOnDate along with its JMS properties ! * @param tm ! * @param properties ! * @param queueOnDate ! */ ! public void schedule(TolvenMessage tm, Map<String, Object> properties, Date queueOnDate); ! ! /** ! * Unwrap TolvenMessage from an objectMessage ! * @param objectMessage ! */ public TolvenMessage unwrapTolvenMessage(ObjectMessage objectMessage); |
From: Joseph I. <jos...@us...> - 2011-01-17 10:13:51
|
Update of /cvsroot/tolven/tolvenEJB/src/org/tolven/gen/bean In directory sfp-cvsdas-2.v30.ch3.sourceforge.com:/tmp/cvs-serv26148/src/org/tolven/gen/bean Modified Files: Tag: V2 GenDriver.java Log Message: When multiple messages are queued, they are all queued using one connection Index: GenDriver.java =================================================================== RCS file: /cvsroot/tolven/tolvenEJB/src/org/tolven/gen/bean/GenDriver.java,v retrieving revision 1.18.10.4 retrieving revision 1.18.10.5 diff -C2 -d -r1.18.10.4 -r1.18.10.5 *** GenDriver.java 24 Dec 2010 01:13:32 -0000 1.18.10.4 --- GenDriver.java 17 Jan 2011 10:13:43 -0000 1.18.10.5 *************** *** 15,18 **** --- 15,21 ---- import java.io.ByteArrayOutputStream; + import java.io.Serializable; + import java.util.ArrayList; + import java.util.List; import javax.annotation.Resource; *************** *** 95,98 **** --- 98,102 ---- //TolvenLogger.info("MsgID: " + msg.getJMSMessageID() + " "+ control + " Principal:" + ctx.getCallerPrincipal().getName(), GenDriver.class); int count = 0; + List<Serializable> familyControls = new ArrayList<Serializable>(); while (count < control.getCount()) { FamilyUnit family = familyGen.generateFamily(null, control.getNow()); *************** *** 103,109 **** familyControl.setUserId(control.getUserId()); familyControl.setStartYear(control.getStartYear()); ! generatorQueueBean.send(familyControl); count = count + familyControl.getFamilyUnit().getMembers().size(); } TolvenLogger.info("***Done generating families***", GenDriver.class); return; --- 107,114 ---- familyControl.setUserId(control.getUserId()); familyControl.setStartYear(control.getStartYear()); ! familyControls.add(familyControl); count = count + familyControl.getFamilyUnit().getMembers().size(); } + generatorQueueBean.send(familyControls); TolvenLogger.info("***Done generating families***", GenDriver.class); return; *************** *** 136,139 **** --- 141,145 ---- String baseSeq = "" + control.getNow().getTime(); int seq = 0; + List<TolvenMessage> tms = new ArrayList<TolvenMessage>(); for (FamilyMember member : control.getFamilyUnit().getMembers()) { generator.setVp(member.getPerson()); *************** *** 151,157 **** xmlBean.marshalCCR(ccr, output); accountProcessingProctectionLocal.setAsEncryptedContent(output.toByteArray(), tm); ! tmSchedulerBean.queue(tm); // TolvenLogger.info(tm.getPayload()); } TolvenLogger.info("Finished generating: " + control, GenDriver.class); } --- 157,166 ---- xmlBean.marshalCCR(ccr, output); accountProcessingProctectionLocal.setAsEncryptedContent(output.toByteArray(), tm); ! tms.add(tm); // TolvenLogger.info(tm.getPayload()); } + if(!tms.isEmpty()) { + tmSchedulerBean.queue(tms); + } TolvenLogger.info("Finished generating: " + control, GenDriver.class); } |
Update of /cvsroot/tolven/tolvenEJB/src/org/tolven/queue/bean In directory sfp-cvsdas-2.v30.ch3.sourceforge.com:/tmp/cvs-serv26148/src/org/tolven/queue/bean Modified Files: Tag: V2 RuleQueueBean.java InvitationQueueBean.java AdminAppQueueBean.java GeneratorQueueBean.java Log Message: When multiple messages are queued, they are all queued using one connection Index: GeneratorQueueBean.java =================================================================== RCS file: /cvsroot/tolven/tolvenEJB/src/org/tolven/queue/bean/Attic/GeneratorQueueBean.java,v retrieving revision 1.1.2.3 retrieving revision 1.1.2.4 diff -C2 -d -r1.1.2.3 -r1.1.2.4 *** GeneratorQueueBean.java 12 Aug 2010 00:56:43 -0000 1.1.2.3 --- GeneratorQueueBean.java 17 Jan 2011 10:13:43 -0000 1.1.2.4 *************** *** 18,24 **** import java.io.Serializable; import javax.annotation.Resource; - import javax.annotation.security.RolesAllowed; import javax.ejb.Local; import javax.ejb.Stateless; --- 18,25 ---- import java.io.Serializable; + import java.util.ArrayList; + import java.util.List; import javax.annotation.Resource; import javax.ejb.Local; import javax.ejb.Stateless; *************** *** 57,62 **** --- 58,79 ---- } + /** + * Queue a payload. + * @param payload + */ @Override public void send(Serializable payload) { + List<Serializable> payloads = new ArrayList<Serializable>(1); + payloads.add(payload); + send(payloads); + } + + /** + * Queue a list of payloads. + * One connection is used to send the List of payloads + * @param payloads + */ + @Override + public void send(List<Serializable> payloads) { Connection connection = null; try { *************** *** 64,71 **** Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); MessageProducer messageProducer = session.createProducer(generatorQueue); ! ObjectMessage message = session.createObjectMessage(payload); ! messageProducer.send(message); } catch (JMSException ex) { ! throw new RuntimeException("Failed to send payload to queue: " + getQueueName(), ex); } finally { try { --- 81,91 ---- Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); MessageProducer messageProducer = session.createProducer(generatorQueue); ! ObjectMessage message = null; ! for (Serializable payload : payloads) { ! message = session.createObjectMessage(payload); ! messageProducer.send(message); ! } } catch (JMSException ex) { ! throw new RuntimeException("Failed to send " + payloads.size() + " payload(s) to queue: " + getQueueName(), ex); } finally { try { *************** *** 78,81 **** } } ! } --- 98,101 ---- } } ! } Index: AdminAppQueueBean.java =================================================================== RCS file: /cvsroot/tolven/tolvenEJB/src/org/tolven/queue/bean/Attic/AdminAppQueueBean.java,v retrieving revision 1.1.2.3 retrieving revision 1.1.2.4 diff -C2 -d -r1.1.2.3 -r1.1.2.4 *** AdminAppQueueBean.java 12 Aug 2010 00:56:43 -0000 1.1.2.3 --- AdminAppQueueBean.java 17 Jan 2011 10:13:43 -0000 1.1.2.4 *************** *** 18,24 **** import java.io.Serializable; import javax.annotation.Resource; - import javax.annotation.security.RolesAllowed; import javax.ejb.Local; import javax.ejb.Stateless; --- 18,25 ---- import java.io.Serializable; + import java.util.ArrayList; + import java.util.List; import javax.annotation.Resource; import javax.ejb.Local; import javax.ejb.Stateless; *************** *** 58,63 **** --- 59,80 ---- } + /** + * Queue a payload. + * @param payload + */ @Override public void send(Serializable payload) { + List<Serializable> payloads = new ArrayList<Serializable>(1); + payloads.add(payload); + send(payloads); + } + + /** + * Queue a list of payloads. + * One connection is used to send the List of payloads + * @param payloads + */ + @Override + public void send(List<Serializable> payloads) { Connection connection = null; try { *************** *** 65,70 **** Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); MessageProducer messageProducer = session.createProducer(adminAppQueue); ! ObjectMessage message = session.createObjectMessage(payload); ! messageProducer.send(message); } catch (JMSException ex) { throw new RuntimeException("Failed to send payload to queue: " + getQueueName(), ex); --- 82,90 ---- Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); MessageProducer messageProducer = session.createProducer(adminAppQueue); ! ObjectMessage message = null; ! for (Serializable payload : payloads) { ! message = session.createObjectMessage(payload); ! messageProducer.send(message); ! } } catch (JMSException ex) { throw new RuntimeException("Failed to send payload to queue: " + getQueueName(), ex); Index: InvitationQueueBean.java =================================================================== RCS file: /cvsroot/tolven/tolvenEJB/src/org/tolven/queue/bean/Attic/InvitationQueueBean.java,v retrieving revision 1.1.2.3 retrieving revision 1.1.2.4 diff -C2 -d -r1.1.2.3 -r1.1.2.4 *** InvitationQueueBean.java 12 Aug 2010 00:56:43 -0000 1.1.2.3 --- InvitationQueueBean.java 17 Jan 2011 10:13:43 -0000 1.1.2.4 *************** *** 18,24 **** import java.io.Serializable; import javax.annotation.Resource; - import javax.annotation.security.RolesAllowed; import javax.ejb.Local; import javax.ejb.Stateless; --- 18,25 ---- import java.io.Serializable; + import java.util.ArrayList; + import java.util.List; import javax.annotation.Resource; import javax.ejb.Local; import javax.ejb.Stateless; *************** *** 57,62 **** --- 58,79 ---- } + /** + * Queue a payload. + * @param payload + */ @Override public void send(Serializable payload) { + List<Serializable> payloads = new ArrayList<Serializable>(1); + payloads.add(payload); + send(payloads); + } + + /** + * Queue a list of payloads. + * One connection is used to send the List of payloads + * @param payloads + */ + @Override + public void send(List<Serializable> payloads) { Connection connection = null; try { *************** *** 64,69 **** Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); MessageProducer messageProducer = session.createProducer(invitationQueue); ! ObjectMessage message = session.createObjectMessage(payload); ! messageProducer.send(message); } catch (JMSException ex) { throw new RuntimeException("Failed to send payload to queue: " + getQueueName(), ex); --- 81,89 ---- Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); MessageProducer messageProducer = session.createProducer(invitationQueue); ! ObjectMessage message = null; ! for (Serializable payload : payloads) { ! message = session.createObjectMessage(payload); ! messageProducer.send(message); ! } } catch (JMSException ex) { throw new RuntimeException("Failed to send payload to queue: " + getQueueName(), ex); Index: RuleQueueBean.java =================================================================== RCS file: /cvsroot/tolven/tolvenEJB/src/org/tolven/queue/bean/Attic/RuleQueueBean.java,v retrieving revision 1.1.2.3 retrieving revision 1.1.2.4 diff -C2 -d -r1.1.2.3 -r1.1.2.4 *** RuleQueueBean.java 12 Aug 2010 00:56:43 -0000 1.1.2.3 --- RuleQueueBean.java 17 Jan 2011 10:13:43 -0000 1.1.2.4 *************** *** 18,25 **** import java.io.Serializable; import java.util.Map; import javax.annotation.Resource; - import javax.annotation.security.RolesAllowed; import javax.ejb.Local; import javax.ejb.Stateless; --- 18,26 ---- import java.io.Serializable; + import java.util.ArrayList; + import java.util.List; import java.util.Map; import javax.annotation.Resource; import javax.ejb.Local; import javax.ejb.Stateless; *************** *** 60,90 **** } @Override public void send(Serializable payload) { ! send(payload, null); } @Override public void send(Serializable payload, Map<String, Object> properties) { Connection connection = null; try { connection = connectionFactory.createConnection(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); MessageProducer messageProducer = session.createProducer(ruleQueue); ! boolean isTolvenMessage = payload instanceof TolvenMessage; ! ObjectMessage message = null; ! if (isTolvenMessage) { ! TolvenMessage tm = (TolvenMessage) payload; ! TolvenMessageInfo info = new TolvenMessageInfo(tm.getId()); ! message = session.createObjectMessage(info); ! } else { ! message = session.createObjectMessage(payload); ! } ! if (properties != null) { ! for (String key : properties.keySet()) { ! message.setObjectProperty(key, properties.get(key)); } } - messageProducer.send(message); } catch (JMSException ex) { throw new RuntimeException("Failed to send payload to queue: " + getQueueName(), ex); --- 61,135 ---- } + /** + * Queue a payload + * @param payload + */ @Override public void send(Serializable payload) { ! List<Serializable> payloads = new ArrayList<Serializable>(1); ! payloads.add(payload); ! send(payloads, null); ! } ! ! /** ! * Queue payloads ! * One connection is used to send the List of payloads ! * @param payloads ! */ ! @Override ! public void send(List<Serializable> payloads) { ! send(payloads, null); } + /** + * Queue a payload along with its JMS properties + * @param payload + * @param properties + */ @Override public void send(Serializable payload, Map<String, Object> properties) { + List<Serializable> payloads = new ArrayList<Serializable>(1); + payloads.add(payload); + List<Map<String, Object>> listOfProperties = new ArrayList<Map<String, Object>>(1); + listOfProperties.add(properties); + send(payloads, listOfProperties); + } + + /** + * Queue a list of payloads along with their JMS properties. Each payload must have a corresponding + * properties map, even if that map is empty + * One connection is used to send the List of payloads + * @param payloads + * @param listOfProperties + */ + @Override + public void send(List<Serializable> payloads, List<Map<String, Object>> listOfProperties) { Connection connection = null; try { + if (listOfProperties != null && !listOfProperties.isEmpty() && listOfProperties.size() != payloads.size()) { + throw new RuntimeException("The listOfProperties length does not match the number of payloads"); + } connection = connectionFactory.createConnection(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); MessageProducer messageProducer = session.createProducer(ruleQueue); ! for (int i = 0; i < payloads.size(); i++) { ! Serializable payload = payloads.get(i); ! boolean isTolvenMessage = payload instanceof TolvenMessage; ! ObjectMessage message = null; ! if (isTolvenMessage) { ! TolvenMessage tm = (TolvenMessage) payload; ! TolvenMessageInfo info = new TolvenMessageInfo(tm.getId()); ! message = session.createObjectMessage(info); ! } else { ! message = session.createObjectMessage(payload); } + if (listOfProperties != null && !listOfProperties.isEmpty()) { + Map<String, Object> properties = listOfProperties.get(i); + for (String key : properties.keySet()) { + message.setObjectProperty(key, properties.get(key)); + } + } + messageProducer.send(message); } } catch (JMSException ex) { throw new RuntimeException("Failed to send payload to queue: " + getQueueName(), ex); |
From: Joseph I. <jos...@us...> - 2011-01-17 10:13:51
|
Update of /cvsroot/tolven/tolvenEJB/src/org/tolven/doc/bean In directory sfp-cvsdas-2.v30.ch3.sourceforge.com:/tmp/cvs-serv26148/src/org/tolven/doc/bean Modified Files: Tag: V2 TolvenMessageScheduler.java Log Message: When multiple messages are queued, they are all queued using one connection Index: TolvenMessageScheduler.java =================================================================== RCS file: /cvsroot/tolven/tolvenEJB/src/org/tolven/doc/bean/TolvenMessageScheduler.java,v retrieving revision 1.2.8.4 retrieving revision 1.2.8.5 diff -C2 -d -r1.2.8.4 -r1.2.8.5 *** TolvenMessageScheduler.java 24 Dec 2010 01:13:32 -0000 1.2.8.4 --- TolvenMessageScheduler.java 17 Jan 2011 10:13:43 -0000 1.2.8.5 *************** *** 64,67 **** --- 64,68 ---- private Logger logger = Logger.getLogger(TolvenMessageScheduler.class); + @Override public void setScheduler(long interval) { stopScheduler(); *************** *** 75,78 **** --- 76,80 ---- } + @Override public void stopScheduler() { for (Object obj : ejbContext.getTimerService().getTimers()) { *************** *** 82,85 **** --- 84,88 ---- } + @Override public Date getNextTimeout() { Timer timer = null; *************** *** 101,104 **** --- 104,108 ---- * @return */ + @Override public TolvenMessage findTolvenMessage(long id) { return em.find(TolvenMessage.class, id); *************** *** 106,127 **** /** ! * Queue a message immediately */ public void queue(TolvenMessage tm) { ! schedule(tm, null, null); } /** ! * Queue a message immediately, with properties for the JMS message */ public void queue(TolvenMessage tm, Map<String, Object> properties) { ! schedule(tm, null, properties); } /** ! * Schedule a message to be queued on queuOnDate */ public void schedule(TolvenMessage tm, Date queueOnDate) { ! schedule(tm, queueOnDate, null); } --- 110,161 ---- /** ! * Queue a TolvenMessage. ! * @param tm */ + @Override public void queue(TolvenMessage tm) { ! schedule(tm, new HashMap<String, Object>(0), null); } /** ! * Queue a list of TolvenMessages. ! * One connection is used to send the List of TolvenMessages ! * @param tms */ + @Override + public void queue(List<TolvenMessage> tms) { + schedule(tms, new ArrayList<Map<String, Object>>(0), null); + } + + /** + * Queue a TolvenMessage along with its JMS properties + * @param tm + * @param properties + */ + @Override public void queue(TolvenMessage tm, Map<String, Object> properties) { ! schedule(tm, properties, null); } /** ! * Queue a list of TolvenMessages along with their JMS properties. Each TolvenMessage must have a corresponding ! * properties map, even if that map is empty ! * A separate connection is used for each payload ! * @param tms ! * @param listOfProperties ! */ ! @Override ! public void queue(List<TolvenMessage> tms, List<Map<String, Object>> listOfProperties) { ! schedule(tms, listOfProperties, null); ! } ! ! /** ! * Schedule a TolvenMessage to be queued on queueOnDate ! * @param tm ! * @param queueOnDate */ + @Override public void schedule(TolvenMessage tm, Date queueOnDate) { ! schedule(tm, new HashMap<String, Object>(0), queueOnDate); } *************** *** 129,151 **** * Schedule a message to a queued on queueOnDate, with properties for the JMS message * If the queueOnDate is null, then the message is queued immediately */ ! public void schedule(TolvenMessage tm, Date queueOnDate, Map<String, Object> properties) { ! if (properties != null) { ! for (String key : properties.keySet()) { ! TolvenMessageProperty tmp = new TolvenMessageProperty(key); ! tmp.setObject(properties.get(key)); ! tm.getProperties().add(tmp); ! } } Date now = new Date(); ! tm.setScheduleDate(now); ! em.persist(tm); if (queueOnDate == null) { - List<TolvenMessage> tms = new ArrayList<TolvenMessage>(); - tms.add(tm); queueMessages(tms, now); - } else { - tm.setQueueOnDate(queueOnDate); - logger.info("TolvenMessage " + tm.getId() + " scheduled for " + ruleQueueBean.getQueueName() + " at " + queueOnDate); } } --- 163,211 ---- * Schedule a message to a queued on queueOnDate, with properties for the JMS message * If the queueOnDate is null, then the message is queued immediately + * @param tm + * @param properties + * @param queueOnDate */ ! @Override ! public void schedule(TolvenMessage tm, Map<String, Object> properties, Date queueOnDate) { ! List<TolvenMessage> tms = new ArrayList<TolvenMessage>(1); ! tms.add(tm); ! List<Map<String, Object>> listOfProperties = new ArrayList<Map<String, Object>>(1); ! listOfProperties.add(properties); ! schedule(tms, listOfProperties, queueOnDate); ! } ! ! /** ! * Schedule a list of TolvenMessages to be queued on queueOnDate, along with their JMS properties. ! * If the queueOnDate is null, then the message is queued immediately ! * @param tms ! * @param listOfProperties ! * @param queueOnDate ! */ ! public void schedule(List<TolvenMessage> tms, List<Map<String, Object>> listOfProperties, Date queueOnDate) { ! //timeNow should be passed to the EJB tier ! if (listOfProperties != null && !listOfProperties.isEmpty() && listOfProperties.size() != tms.size()) { ! throw new RuntimeException("The listOfProperties length does not match the number of TolvenMessages"); } Date now = new Date(); ! for (int i = 0; i < tms.size(); i++) { ! TolvenMessage tm = tms.get(i); ! if (listOfProperties != null && !listOfProperties.isEmpty()) { ! Map<String, Object> properties = listOfProperties.get(i); ! for (String key : properties.keySet()) { ! TolvenMessageProperty tmp = new TolvenMessageProperty(key); ! tmp.setObject(properties.get(key)); ! tm.getProperties().add(tmp); ! } ! } ! tm.setScheduleDate(now); ! em.persist(tm); ! if (queueOnDate != null) { ! tm.setQueueOnDate(queueOnDate); ! logger.info("TolvenMessage " + tm.getId() + " scheduled for " + ruleQueueBean.getQueueName() + " at " + queueOnDate); ! } ! } if (queueOnDate == null) { queueMessages(tms, now); } } *************** *** 200,203 **** --- 260,268 ---- } + /** + * Unwrap TolvenMessage from an objectMessage + * @param objectMessage + */ + @Override public TolvenMessage unwrapTolvenMessage(ObjectMessage objectMessage) { TolvenMessage tm = null; |
From: Joseph I. <jos...@us...> - 2011-01-17 10:13:51
|
Update of /cvsroot/tolven/tolvenEJB/src/org/tolven/app In directory sfp-cvsdas-2.v30.ch3.sourceforge.com:/tmp/cvs-serv26148/src/org/tolven/app Modified Files: Tag: V2 AdminAppQueueLocal.java Log Message: When multiple messages are queued, they are all queued using one connection Index: AdminAppQueueLocal.java =================================================================== RCS file: /cvsroot/tolven/tolvenEJB/src/org/tolven/app/Attic/AdminAppQueueLocal.java,v retrieving revision 1.1.2.1 retrieving revision 1.1.2.2 diff -C2 -d -r1.1.2.1 -r1.1.2.2 *** AdminAppQueueLocal.java 29 Apr 2010 01:47:00 -0000 1.1.2.1 --- AdminAppQueueLocal.java 17 Jan 2011 10:13:43 -0000 1.1.2.2 *************** *** 15,18 **** --- 15,19 ---- import java.io.Serializable; + import java.util.List; public interface AdminAppQueueLocal { *************** *** 20,25 **** --- 21,37 ---- public String getQueueName(); + /** + * Queue a payload + * @param payload + */ public void send(Serializable payload); + /** + * Queue a list of payloads + * One connection is used to send the List of payloads + * @param payloads + */ + public void send(List<Serializable> payloads); + public void queueActivateNewTrimHeaders( ); |
From: Joseph I. <jos...@us...> - 2011-01-17 10:13:51
|
Update of /cvsroot/tolven/tolvenEJB/src/org/tolven/gen In directory sfp-cvsdas-2.v30.ch3.sourceforge.com:/tmp/cvs-serv26148/src/org/tolven/gen Modified Files: Tag: V2 GeneratorQueueLocal.java Log Message: When multiple messages are queued, they are all queued using one connection Index: GeneratorQueueLocal.java =================================================================== RCS file: /cvsroot/tolven/tolvenEJB/src/org/tolven/gen/Attic/GeneratorQueueLocal.java,v retrieving revision 1.1.2.1 retrieving revision 1.1.2.2 diff -C2 -d -r1.1.2.1 -r1.1.2.2 *** GeneratorQueueLocal.java 29 Apr 2010 01:47:00 -0000 1.1.2.1 --- GeneratorQueueLocal.java 17 Jan 2011 10:13:43 -0000 1.1.2.2 *************** *** 15,18 **** --- 15,19 ---- import java.io.Serializable; + import java.util.List; public interface GeneratorQueueLocal { *************** *** 20,24 **** --- 21,36 ---- public String getQueueName(); + /** + * Queue a payload. + * @param payload + */ public void send(Serializable payload); + /** + * Queue a list of payloads. + * One connection is used to send the List of payloads + * @param payloads + */ + public void send(List<Serializable> payloads); + } |
From: Joseph I. <jos...@us...> - 2011-01-17 10:13:51
|
Update of /cvsroot/tolven/tolvenEJB/src/org/tolven/core In directory sfp-cvsdas-2.v30.ch3.sourceforge.com:/tmp/cvs-serv26148/src/org/tolven/core Modified Files: Tag: V2 InvitationQueueLocal.java Log Message: When multiple messages are queued, they are all queued using one connection Index: InvitationQueueLocal.java =================================================================== RCS file: /cvsroot/tolven/tolvenEJB/src/org/tolven/core/Attic/InvitationQueueLocal.java,v retrieving revision 1.1.2.1 retrieving revision 1.1.2.2 diff -C2 -d -r1.1.2.1 -r1.1.2.2 *** InvitationQueueLocal.java 29 Apr 2010 01:47:00 -0000 1.1.2.1 --- InvitationQueueLocal.java 17 Jan 2011 10:13:43 -0000 1.1.2.2 *************** *** 15,18 **** --- 15,19 ---- import java.io.Serializable; + import java.util.List; public interface InvitationQueueLocal { *************** *** 20,24 **** --- 21,36 ---- public String getQueueName(); + /** + * Queue a payload. + * @param payload + */ public void send(Serializable payload); + /** + * Queue a list of payloads. + * One connection is used to send the List of payloads + * @param payloads + */ + public void send(List<Serializable> payloads); + } |
From: Joseph I. <jos...@us...> - 2011-01-16 08:11:12
|
Update of /cvsroot/tolven/pluginGlassfishPostgresqlConfig/pre-tolven-glassfish3-postgresql/glassfish/domains/tolven/imq/instances/imqbroker/props In directory sfp-cvsdas-2.v30.ch3.sourceforge.com:/tmp/cvs-serv12913/pre-tolven-glassfish3-postgresql/glassfish/domains/tolven/imq/instances/imqbroker/props Modified Files: Tag: V2 config.properties Log Message: Changed config.properties to use SSL by default Index: config.properties =================================================================== RCS file: /cvsroot/tolven/pluginGlassfishPostgresqlConfig/pre-tolven-glassfish3-postgresql/glassfish/domains/tolven/imq/instances/imqbroker/props/Attic/config.properties,v retrieving revision 1.1.2.1 retrieving revision 1.1.2.2 diff -C2 -d -r1.1.2.1 -r1.1.2.2 *** config.properties 16 Jan 2011 07:12:02 -0000 1.1.2.1 --- config.properties 16 Jan 2011 08:11:04 -0000 1.1.2.2 *************** *** 40,45 **** imq.persist.store=jdbc imq.persist.jdbc.dbVendor=postgresql ! imq.persist.jdbc.postgresql.opendburl=jdbc:postgresql://localhost:5432/postgres ! imq.persist.jdbc.postgresql.closedburl=jdbc:postgresql://localhost:5432/postgres imq.persist.jdbc.postgresql.user=postgres imq.persist.jdbc.postgresql.password=postgres --- 40,45 ---- imq.persist.store=jdbc imq.persist.jdbc.dbVendor=postgresql ! imq.persist.jdbc.postgresql.opendburl=jdbc:postgresql://localhost:5432/postgres?ssl=true ! imq.persist.jdbc.postgresql.closedburl=jdbc:postgresql://localhost:5432/postgres?ssl=true imq.persist.jdbc.postgresql.user=postgres imq.persist.jdbc.postgresql.password=postgres |
From: Joseph I. <jos...@us...> - 2011-01-16 07:30:55
|
Update of /cvsroot/tolven/pluginGlassfishPostgresqlConfig/post-tolven-glassfish3-postgresql/glassfish/domains/tolven/imq/instances In directory sfp-cvsdas-2.v30.ch3.sourceforge.com:/tmp/cvs-serv31275/post-tolven-glassfish3-postgresql/glassfish/domains/tolven/imq/instances Log Message: Directory /cvsroot/tolven/pluginGlassfishPostgresqlConfig/post-tolven-glassfish3-postgresql/glassfish/domains/tolven/imq/instances added to the repository |
From: Joseph I. <jos...@us...> - 2011-01-16 07:30:49
|
Update of /cvsroot/tolven/pluginGlassfishPostgresqlConfig/pre-tolven-glassfish3-postgresql/glassfish/domains/tolven/imq In directory sfp-cvsdas-2.v30.ch3.sourceforge.com:/tmp/cvs-serv31275/pre-tolven-glassfish3-postgresql/glassfish/domains/tolven/imq Log Message: Directory /cvsroot/tolven/pluginGlassfishPostgresqlConfig/pre-tolven-glassfish3-postgresql/glassfish/domains/tolven/imq added to the repository |
From: Joseph I. <jos...@us...> - 2011-01-16 07:30:44
|
Update of /cvsroot/tolven/pluginGlassfishPostgresqlConfig/post-tolven-glassfish3-postgresql/glassfish/domains/tolven/imq/instances/imqbroker In directory sfp-cvsdas-2.v30.ch3.sourceforge.com:/tmp/cvs-serv31275/post-tolven-glassfish3-postgresql/glassfish/domains/tolven/imq/instances/imqbroker Log Message: Directory /cvsroot/tolven/pluginGlassfishPostgresqlConfig/post-tolven-glassfish3-postgresql/glassfish/domains/tolven/imq/instances/imqbroker added to the repository |
From: Joseph I. <jos...@us...> - 2011-01-16 07:30:38
|
Update of /cvsroot/tolven/pluginGlassfishPostgresqlConfig/pre-tolven-glassfish3-postgresql/mq/etc In directory sfp-cvsdas-2.v30.ch3.sourceforge.com:/tmp/cvs-serv31275/pre-tolven-glassfish3-postgresql/mq/etc Log Message: Directory /cvsroot/tolven/pluginGlassfishPostgresqlConfig/pre-tolven-glassfish3-postgresql/mq/etc added to the repository |
From: Joseph I. <jos...@us...> - 2011-01-16 07:30:32
|
Update of /cvsroot/tolven/pluginGlassfishPostgresqlConfig/post-tolven-glassfish3-postgresql/glassfish/domains/tolven/imq In directory sfp-cvsdas-2.v30.ch3.sourceforge.com:/tmp/cvs-serv31275/post-tolven-glassfish3-postgresql/glassfish/domains/tolven/imq Log Message: Directory /cvsroot/tolven/pluginGlassfishPostgresqlConfig/post-tolven-glassfish3-postgresql/glassfish/domains/tolven/imq added to the repository |
From: Joseph I. <jos...@us...> - 2011-01-16 07:30:21
|
Update of /cvsroot/tolven/pluginGlassfishOracleConfig/post-tolven-glassfish3-oracle/glassfish In directory sfp-cvsdas-2.v30.ch3.sourceforge.com:/tmp/cvs-serv31414/post-tolven-glassfish3-oracle/glassfish Log Message: Directory /cvsroot/tolven/pluginGlassfishOracleConfig/post-tolven-glassfish3-oracle/glassfish added to the repository |
From: Joseph I. <jos...@us...> - 2011-01-16 07:30:15
|
Update of /cvsroot/tolven/pluginGlassfishPostgresqlConfig/post-tolven-glassfish3-postgresql/glassfish/domains/tolven/imq/instances/imqbroker/etc In directory sfp-cvsdas-2.v30.ch3.sourceforge.com:/tmp/cvs-serv31571/post-tolven-glassfish3-postgresql/glassfish/domains/tolven/imq/instances/imqbroker/etc Added Files: Tag: V2 accesscontrol.properties Log Message: The project organized to show files that were in zips in the repository, but the same plugin zip organization is built --- NEW FILE: accesscontrol.properties --- ########################################################## # MQ access control file for JMQFileAccessControlModel ########################################################## version=JMQFileAccessControlModel/100 ######################################################## # Please see the MQ Administration Guide for details # on how to customize access control # # (spaces in a rule are significant) ######################################################## # service connection access control ################################## #connection.NORMAL.allow.user=* #connection.ADMIN.allow.group=admin # destination based access control ################################## #queue.*.produce.allow.user=* #queue.*.consume.allow.user=* #queue.*.browse.allow.user=* #topic.*.produce.allow.user=* #topic.*.consume.allow.user=* # destination auto-create access control ######################################## #queue.create.allow.user=* #topic.create.allow.user=* # all permissions access control setup sample ############################################## #connection.*.usernames=* # #queue.*.produce.allow.user=* #queue.*.consume.allow.user=* #queue.*.browse.allow.user=* #topic.*.produce.allow.user=* #topic.*.consume.allow.user=* #queue.create.allow.user=* #topic.create.allow.user=* ############################################## connection.NORMAL.allow.user=admin connection.ADMIN.allow.user=admin |
From: Joseph I. <jos...@us...> - 2011-01-16 07:30:10
|
Update of /cvsroot/tolven/pluginGlassfishOracleConfig/post-tolven-glassfish3-oracle/glassfish/domains/tolven/config In directory sfp-cvsdas-2.v30.ch3.sourceforge.com:/tmp/cvs-serv31414/post-tolven-glassfish3-oracle/glassfish/domains/tolven/config Log Message: Directory /cvsroot/tolven/pluginGlassfishOracleConfig/post-tolven-glassfish3-oracle/glassfish/domains/tolven/config added to the repository |
From: Joseph I. <jos...@us...> - 2011-01-16 07:30:04
|
Update of /cvsroot/tolven/pluginGlassfishOracleConfig/post-tolven-glassfish3-oracle/glassfish/domains/tolven/imq/instances/imqbroker/etc In directory sfp-cvsdas-2.v30.ch3.sourceforge.com:/tmp/cvs-serv31414/post-tolven-glassfish3-oracle/glassfish/domains/tolven/imq/instances/imqbroker/etc Log Message: Directory /cvsroot/tolven/pluginGlassfishOracleConfig/post-tolven-glassfish3-oracle/glassfish/domains/tolven/imq/instances/imqbroker/etc added to the repository |
From: Joseph I. <jos...@us...> - 2011-01-16 07:29:58
|
Update of /cvsroot/tolven/pluginGlassfishOracleConfig/post-tolven-glassfish3-oracle/glassfish/domains/tolven/lib In directory sfp-cvsdas-2.v30.ch3.sourceforge.com:/tmp/cvs-serv31414/post-tolven-glassfish3-oracle/glassfish/domains/tolven/lib Log Message: Directory /cvsroot/tolven/pluginGlassfishOracleConfig/post-tolven-glassfish3-oracle/glassfish/domains/tolven/lib added to the repository |
From: Joseph I. <jos...@us...> - 2011-01-16 07:29:52
|
Update of /cvsroot/tolven/pluginGlassfishOracleConfig/pre-tolven-glassfish3-oracle/glassfish/domains/tolven/imq/instances/imqbroker In directory sfp-cvsdas-2.v30.ch3.sourceforge.com:/tmp/cvs-serv31414/pre-tolven-glassfish3-oracle/glassfish/domains/tolven/imq/instances/imqbroker Log Message: Directory /cvsroot/tolven/pluginGlassfishOracleConfig/pre-tolven-glassfish3-oracle/glassfish/domains/tolven/imq/instances/imqbroker added to the repository |
From: Joseph I. <jos...@us...> - 2011-01-16 07:29:47
|
Update of /cvsroot/tolven/pluginGlassfishOracleConfig/pre-tolven-glassfish3-oracle/mq/etc In directory sfp-cvsdas-2.v30.ch3.sourceforge.com:/tmp/cvs-serv31414/pre-tolven-glassfish3-oracle/mq/etc Log Message: Directory /cvsroot/tolven/pluginGlassfishOracleConfig/pre-tolven-glassfish3-oracle/mq/etc added to the repository |
From: Joseph I. <jos...@us...> - 2011-01-16 07:14:12
|
Update of /cvsroot/tolven/pluginGlassfishOracleConfig/pre-tolven-glassfish3-oracle/mq/etc In directory sfp-cvsdas-2.v30.ch3.sourceforge.com:/tmp/cvs-serv32199/pre-tolven-glassfish3-oracle/mq/etc Added Files: Tag: V2 imqenv.conf Log Message: The project organized to show files that were in zips in the repository, but the same plugin zip organization is built --- NEW FILE: imqenv.conf --- #!/bin/sh ############################################################################# # # DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER. # # Copyright 2000-2007 Sun Microsystems, Inc. All rights reserved. # # The contents of this file are subject to the terms of either the GNU # General Public License Version 2 only ("GPL") or the Common Development # and Distribution License ("CDDL") (collectively, the "License"). You may # not use this file except in compliance with the License. You can obtain # a copy of the License at https://glassfish.dev.java.net/public/CDDL+GPL.html # or mq/legal/LICENSE.txt. See the License for the specific language # governing permissions and limitations under the License. # # When distributing the software, include this License Header Notice in each # file and include the License file at mq/legal/LICENSE.txt. Sun designates # this particular file as subject to the "Classpath" exception as provided by # Sun in the GPL Version 2 section of the License file that accompanied this # code. If applicable, add the following below the License Header, with the # fields enclosed by brackets [] replaced by your own identifying information: # "Portions Copyrighted [year] [name of copyright owner]" # # Contributor(s): # # If you wish your version of this file to be governed by only the CDDL or # only the GPL Version 2, indicate your decision by adding "[Contributor] # elects to include this software in this distribution under the [CDDL or GPL # Version 2] license." If you don't indicate a single choice of license, a # recipient has the option to distribute your version of this file under # either the CDDL, the GPL Version 2 or to extend the choice of license to # its licensees as provided above. However, if you add GPL Version 2 code # and therefore, elected the GPL Version 2 license, then the option applies # only if the new code is made subject to such option by the copyright holder. # # # @(#)imqenv.conf 1.7 08/14/07 # ############################################################################# # # Default location of J2SE # IMQ_DEFAULT_JAVAHOME=/usr/java # # Default location of MQ's "/var" filesystem # IMQ_DEFAULT_VARHOME=/var/imq # # Default external JARs to be included on the CLASSPATH, # e.g. JDBC drivers and/or JAAS LoginModules. # # This is a ':' separated list of JAR/ZIP files that will be included # on the CLASSPATH. # # The entry in this file includes the JDBC drivers for HADB, Java DB, # and PostgreSQL using their default installed locations. # IMQ_DEFAULT_EXT_JARS=/opt/SUNWhadb/4/lib/hadbjdbc4.jar:/opt/SUNWjavadb/derby.jar:/usr/share/java/postgresql.jar # Set this for Glassfish IMQ_DEFAULT_VARHOME=../../glassfish/domains/tolven/imq |
From: Joseph I. <jos...@us...> - 2011-01-16 07:14:11
|
Update of /cvsroot/tolven/pluginGlassfishOracleConfig/post-tolven-glassfish3-oracle/glassfish/domains/tolven/docroot In directory sfp-cvsdas-2.v30.ch3.sourceforge.com:/tmp/cvs-serv32199/post-tolven-glassfish3-oracle/glassfish/domains/tolven/docroot Added Files: Tag: V2 index.jsp Log Message: The project organized to show files that were in zips in the repository, but the same plugin zip organization is built --- NEW FILE: index.jsp --- <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN""http://www.w3.org/TR/html4/loose.dtd"> <html> <head> <meta http-equiv="Content-Type" content="text/html; charset=UTF-8"> <meta http-equiv="pragma" content="no-cache"> <meta http-equiv="cache-control" content="no-cache"> <meta http-equiv="expires" content="0"> <!-- meta http-equiv="refresh" content="5; url=/Tolven" / --> </head> <body> <h3>Tolven Server</h3> <p>You have reached the Tolven server. To log into the tolven application, click on the link below. You may also want to bookmark the URL below for convenient future access to Tolven.</p> <a href="/Tolven">Tolven Login</a> <h3>A note about security</h3> <p>When you click on the link to login, the Tolven server and your browser will negotiate a private communication channel. Among other things, this provides you an assurance that the server is authentic -- assuming that you verify the authenticy by clicking on the padlock or other icon provided on your browser.</p> <p>If the server you are about to connect to is provided for demonstration or testing, it probably will not have a valid certificate and thus your browser may report that the server should not be trusted. While you should indeed be cautious and not enter private information, you may have been asked to access the software for the purpose of evaluation or testing prior to a "go live" on a server that does have a valid digital certificate.</p> <h3>Technical</h3> <p>Tomcat will redirect to this page if the Tolven application is not currently listening. Likewise, clicking Tolven Login above could return to this page indicating the same thing. </p> <p>This page is not actually part of the Tolven application. Therefore, it can be used to dispatch to various applications managed by the same application server. Or it can be safely removed or replaced with another page if needed.</p> </body> </html> |