Nickolas Case

I solved my issue. I hadn't implemented JTA correctly and I didn't need to. After I reverted my code to JNDI lookup and added the following jars my code worked.

com.bea.core.diagnostics.instrumentor_1.0.1.0.jar
com.bea.core.repackaged.asm_1.5.2.jar
com.bea.core.xml.beaxmlbeans_2.2.0.0


Of course, you'll still need the wlfullclient.jar using the jarbuilder.

Also, you don't want weblogic.jar along with wlfullclient.jar as this can cause errors too.

Cheers!

Hello all!

I have been racking my brain for the last few days trying to convert a standalone java application from a standard database connection to a JNDI lookup on a weblogic server and I can't seem to get it to work.

applicationContext.xml follows:

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd"> <tx:jta-transaction-manager /> <bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> </bean> <bean id="manager" class="mil.af.afccc.jmingest.snow.Manager"> <property name="sniffer" ref="sniffer" /> <property name="processRunner" ref="processRunner" /> </bean> <bean id="entityManagerFactory" class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean"> <property name="persistenceUnitName" value="JMIngestPU" /> <property name="dataSource" ref="dataSourceProxy" /> <property name="jpaProperties"> <props> <prop key="hibernate.transaction.manager_lookup_class">org.hibernate.transaction.WeblogicTransactionManagerLookup </prop> </props> </property> </bean> <bean id="dataSourceProxy" class="net.ttddyy.dsproxy.support.ProxyDataSource"> <property name="dataSource" ref="dataSource" /> <property name="listener" ref="listeners" /> </bean> <bean id="dataSource" class="org.springframework.jndi.JndiObjectFactoryBean"> <property name="jndiName"> <value>IngestDS</value> </property> <property name="jndiEnvironment" value="classpath:jndi.properties" /> </bean> <bean id="snowDataLoader" class="mil.af.afccc.jmingest.snow.data.SnowDataLoader"> <property name="coordConverter" ref="coordConverter" /> <property name="jmSnow25degDAO" ref="jmSnow25degDAO" /> <property name="qcAlgsUtil" ref="qcAlgsUtil" /> </bean> <bean id="coordConverter" class="mil.af.afccc.jmingest.snow.util.CoordConverter" /> <bean id="sniffer" class="mil.af.afccc.jmingest.snow.Sniffer" /> <bean id="processRunner" class="mil.af.afccc.jmingest.snow.ProcessRunner"> <property name="snowDataLoader" ref="snowDataLoader" /> <property name="dtoBuilder" ref="dtoBuilder" /> <property name="badDir" value="${JM_BAD_DIR}" /> </bean> <bean id="dtoBuilder" class="mil.af.afccc.jmingest.snow.ungrib.DtoBuilder"> <property name="ungribber" ref="ungribber" /> </bean> <bean id="ungribber" class="mil.af.afccc.jmingest.snow.ungrib.Ungribber"> <property name="keys"> <map> <entry key="66" value="snowdepth" /> <entry key="175" value="snowage" /> <entry key="129" value="seaiceage" /> <entry key="91" value="seaicemask" /> <entry key="128" value="seaiceconcentration" /> </map> </property> </bean> <bean id="jmSnow25degDAO" class="mil.af.afccc.jmingest.snow.generateddao.JmSnow25degDAO"> <property name="entityManagerFactory" ref="entityManagerFactory" /> </bean> <bean id="listeners" class="net.ttddyy.dsproxy.listener.ChainListener"> <property name="listeners"> <list> <!--<bean class="net.ttddyy.dsproxy.listener.SLF4JQueryLoggingListener"> <property name="logLevel" value="debug" /> </bean> --> <bean class="net.ttddyy.dsproxy.listener.DataSourceQueryCountListener" /> </list> </property> </bean> <bean id="qcAlgsUtil" class="mil.af.afccc.jmingest.snow.util.QCAlgsUtil" /> </beans>

persistence.xml:

<?xml version="1.0" encoding="UTF-8"?> <persistence xmlns="http://java.sun.com/xml/ns/persistence" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://java.sun.com/xml/ns/persistence http://java.sun.com/xml/ns/persistence/persistence_1_0.xsd" version="1.0"> <persistence-unit name="JMIngestPU" transaction-type="JTA"> <provider>org.hibernate.ejb.HibernatePersistence</provider> <class> mil.af.afccc.jmingest.snow.generateddao.JmSnow25deg </class> <class> mil.af.afccc.jmingest.snow.generateddao.JmSnow25degId </class> <properties> <property name="hibernate.dialect" value="org.hibernate.dialect.Oracle10gDialect" /> <property name="hibernate.jdbc.batch_size" value="500" /> <property name="hibernate.temp.use_jdbc_metadata_defaults" value="false" /> </properties> </persistence-unit> </persistence>

I apologize if this isn't the correct forum.

When I get the Runtime object, it shows four processors available and lots of memory. I thought it might be how the command was being sent in one string so I broke the string up into an array and it still failed intermittently. I have googled my issue with no luck.


I am considering rewriting this application but I am afraid the issue will persist. Does anyone have any suggestions?

A little more troubleshooting has revealed when the Process errors out the string isn't parsed and sent to the Process object. Shouldn't that throw a null pointer exception?

I can run the command passed to the exec() method on the command line without a problem. As part of my troubleshooting, I had the command printed out to the console. I have cut and pasted the printout to the command line and it has run every time.

I am consuming the error and output streams associated with the run. From debugging, it looks like the call is never even sent to the system. I ran truss on the command as part of the troubleshooting to see what was going on. When the waitFor() returns a 1, the truss is never executed.

Hello all!

First off, I apologize if this is in the wrong forum.

I have been troubleshooting an intermittent problem where a system call Process automatically returns a waitFor() value of one. There is no rhyme or reason that I can find, nor does any type of error occur.

Has anyone ever experienced this type of behavior?

I am really stumped at this point...

Thanks in advance!

Have you looked at Probe?

Take a look at:
FileSet

Have you solved your issue?

I am also not very good with generics but hopefully my response will get the creative juices flowing for the other guys

The error looks to me like it is looking for the constructor(T,V) and finding (V,T) instead. The compiler, not finding what it is looking for, stops.


Is this a correct assumption or am I way off base?

Yes. My apologies for not stating that up front.

Bag API


The easiest to explain it would be likening it to an online shopping cart. One instance of the object is kept along with a quantity.

Have you looked at using a Bag instead of a Set?

Hello all,

I have a threaded application that can make multiple changes to single rows/fields and the final change is not being persisted through dirty checking.


Examples:
Row 1 has change A made to it. Change A is not persisted
Row 2 has change A made to it, then change B. Only change A is persisted

This is a very heavy application, with changes numbering in the thousands per run. Could this be the culprit?


Unit tests pass which leads me to believe it is a concurrency issue, has anyone ran into this issue before?

some code:


<bean id="entityManagerFactory" class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean"> <bean id="transactionManager" class="org.springframework.orm.jpa.JpaTransactionManager"> <property name="entityManagerFactory" ref="entityManagerFactory" /> </bean> <tx:annotation-driven transaction-manager="transactionManager" />


All threads process similarly...

public void process() { System.out.println("Retrieving wind speed obs."); final List<WindOb> windSpeedObs = dao.getWindSpeedSuspectObs(options.getStartDate(), options.getEndDate()); if (LOG.isDebugEnabled()) { LOG.debug("Processing " + windSpeedObs.size() + " wind speed obs."); } System.out.println("Processing wind speed obs."); for (WindOb windOb : windSpeedObs) { System.out.println("Wind Speed active"); final List<WindOb> temp = new ArrayList<WindOb>(3); try { temp.add(dao.getWindSpeedBeforeReferenceOb(windOb.getJmoOb().getObservationtime(), windOb.getJmoOb().getNetworkType(), windOb.getJmoOb().getPlatformId())); } catch (ParseException e) { LOG.warn("Unable to parse windSpeedBeforeReferenceOb query for observation " + windOb.getObservationId()); } temp.add(windOb); try { temp.add(dao.getWindSpeedAfterReferenceOb(windOb.getJmoOb().getObservationtime(), windOb.getJmoOb().getNetworkType(), windOb.getJmoOb().getPlatformId())); } catch (ParseException e) { LOG.warn("Unable to parse windSpeedAfterReferenceOb query for observation " + windOb.getObservationId()); } List<JmoObservationquality> rejectObs = windAlg3.run(temp); rejectDao.save(rejectObs); public List<JmoObservationquality> run(final List<WindOb> windSpeedObs) { final List<JmoObservationquality> rejectObs = new ArrayList<JmoObservationquality>(2); final WindOb previous = windSpeedObs.get(0); final WindOb suspect = windSpeedObs.get(1); final WindOb following = windSpeedObs.get(2); // Check if wind speed rose more than 25m/s in the previous six hours if (previous != null && suspect != null && suspect.getWindSpeed() != null && previous.getWindSpeed() != null) { final double deltaTimeRising = (suspect.getJmoOb().getObservationtime() - previous.getJmoOb().getObservationtime()) / 10000; final double deltaWindSpeedRising = suspect.getWindSpeed() - previous.getWindSpeed(); if (deltaTimeRising <= 6 && deltaWindSpeedRising >= 25) { suspect.setWindSpeedQualityCode(QualityCode.SUSPECT); LOGGER.info("Observation " + suspect.getObservationId() + "'s wind speed was set to suspect because it increased " + deltaWindSpeedRising + "m/s in " + deltaTimeRising + "hr(s) based on observation " + previous.getObservationId() + "."); // Check if wind speed fell more than 25m/s in the following three hours if (following != null && following.getWindSpeed() != null) { final double deltaTimeFalling = (following.getJmoOb().getObservationtime() - suspect.getJmoOb().getObservationtime()) / 10000; final double deltaWindSpeedFalling = suspect.getWindSpeed() - following.getWindSpeed(); if (deltaTimeFalling <= 3 && deltaWindSpeedFalling >= 25) { rejectObs.add(new JmoObservationquality(suspect.getObservationId(), "WOSPD", suspect.getWindSpeed(), ReasonCode.CONSISTENCY_CHECKS, "W3")); suspect.setWindSpeed(null); suspect.setWindSpeedQualityCode(QualityCode.VALUE_REMOVED); if (suspect.getWindGustSpeed() != null) { rejectObs.add(new JmoObservationquality(suspect.getObservationId(), "WGOSPD", suspect.getWindGustSpeed(), ReasonCode.CONSISTENCY_CHECKS, "W3")); suspect.setWindGustSpeed(null); suspect.setWindGustQualityCode(QualityCode.VALUE_REMOVED); } LOGGER.info("Observation " + suspect.getObservationId() + "'s wind speed was removed because it decreased " + deltaWindSpeedFalling + "m/s in " + deltaTimeFalling + "hr(s) based on observation " + following.getObservationId() + "."); } } } } return rejectObs;

The following code returns all files from the directory. Why?


my $dirh = new DirHandle; opendir $dirh, $incomingDir; my @files = grep {"/^jmobs_\w+_ckgwc\.xml$/"} readdir $dirh; closedir $dirh;

Hello all,

I have an application with multiple threads, each reading different data(possibly from the same rows) from the same table, and makes changes based on data pulled from other pertinent rows in the table. Each thread has its own @Transaction annotation and according to the log, they are all getting their own transaction. The app pulls all data, logs changes to be made, makes the changes to the JPA object etc. fine but the program never persists any of the changes made back to the table.

All my research has led me to believe this should be working.


The flow for my program according to the log file seems to be that each thread gets a transaction, gets an EntityManager, pulls the data, closes the EM, and as they are processing(getting the other pertinent data), getting new EM's for each data pull.



This program was working before I threaded it as it was taking far too long as a single thread application.

I know I haven't given a lot of information out because I don't want to scare anyone away...

I will answer/provide info for any questions.

Thanks in advance for any help!