[Persistence, JBoss/CMP, Hibernate, Database] - DatabaseMetaData and HTTP connections
by wcydaip
Hi,
I began working with the con.getMetaData() object today and soon after began getting the following:
org.jboss.deployment.DeploymentException: Too many open files; - nested throwable: (java.io.IOException: Too many open files)
| at org.jboss.web.AbstractWebContainer.init(AbstractWebContainer.java:352)
| at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
| at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
| at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
| at java.lang.reflect.Method.invoke(Method.java:324)
| at org.jboss.mx.interceptor.ReflectedDispatcher.invoke(ReflectedDispatcher.java:141)
| at org.jboss.mx.server.Invocation.dispatch(Invocation.java:80)
| at org.jboss.mx.interceptor.AbstractInterceptor.invoke(AbstractInterceptor.java:118)
| at org.jboss.mx.server.Invocation.invoke(Invocation.java:74)
| at org.jboss.mx.interceptor.ModelMBeanOperationInterceptor.invoke(ModelMBeanOperationInterceptor.java:127)
| at org.jboss.mx.interceptor.DynamicInterceptor.invoke(DynamicInterceptor.java:80)
| at org.jboss.mx.server.Invocation.invoke(Invocation.java:74)
| at org.jboss.mx.server.AbstractMBeanInvoker.invoke(AbstractMBeanInvoker.java:245)
| at org.jboss.mx.server.MBeanServerImpl.invoke(MBeanServerImpl.java:644)
| at org.jboss.mx.util.MBeanProxyExt.invoke(MBeanProxyExt.java:176)
| at $Proxy31.init(Unknown Source)
| at org.jboss.deployment.MainDeployer.init(MainDeployer.java:843)
| at org.jboss.deployment.MainDeployer.init(MainDeployer.java:863)
| at org.jboss.deployment.MainDeployer.deploy(MainDeployer.java:780)
| at org.jboss.deployment.MainDeployer.deploy(MainDeployer.java:753)
| at sun.reflect.GeneratedMethodAccessor54.invoke(Unknown Source)
| at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
| at java.lang.reflect.Method.invoke(Method.java:324)
| at org.jboss.mx.interceptor.ReflectedDispatcher.invoke(ReflectedDispatcher.java:141)
| at org.jboss.mx.server.Invocation.dispatch(Invocation.java:80)
| at org.jboss.mx.interceptor.AbstractInterceptor.invoke(AbstractInterceptor.java:118)
| at org.jboss.mx.server.Invocation.invoke(Invocation.java:74)
| at org.jboss.mx.interceptor.ModelMBeanOperationInterceptor.invoke(ModelMBeanOperationInterceptor.java:127)
| at org.jboss.mx.server.Invocation.invoke(Invocation.java:74)
| at org.jboss.mx.server.AbstractMBeanInvoker.invoke(AbstractMBeanInvoker.java:245)
| at org.jboss.mx.server.MBeanServerImpl.invoke(MBeanServerImpl.java:644)
| at org.jboss.mx.util.MBeanProxyExt.invoke(MBeanProxyExt.java:176)
| at $Proxy9.deploy(Unknown Source)
| at org.jboss.deployment.scanner.URLDeploymentScanner.deploy(URLDeploymentScanner.java:319)
| at org.jboss.deployment.scanner.URLDeploymentScanner.scan(URLDeploymentScanner.java:489)
| at org.jboss.deployment.scanner.AbstractDeploymentScanner$ScannerThread.doScan(AbstractDeploymentScanner.java:192)
| at org.jboss.deployment.scanner.AbstractDeploymentScanner$ScannerThread.loop(AbstractDeploymentScanner.java:203)
| at org.jboss.deployment.scanner.AbstractDeploymentScanner$ScannerThread.run(AbstractDeploymentScanner.java:182)
| Caused by: java.io.IOException: Too many open files
| at java.io.FileInputStream.open(Native Method)
| at java.io.FileInputStream.<init>(FileInputStream.java:106)
| at org.jboss.web.AbstractWebContainer.init(AbstractWebContainer.java:301)
| ... 37 more
Anyone know the cause?
Here's the code which causes the problem:
public DbTable getTable(String ds, String tbl) throws SQLException, NamingException, LookupException{
| DbTable table = null;
| Connection con = null;
| ResultSet rs = null;
| DatabaseMetaData meta = null;
| String[] types = {"TABLE"};
| try {
| con = AppHelper.getConnection(ds);
| meta = con.getMetaData();
| rs = meta.getTables(con.getCatalog(), null, "%"+tbl+"%", types);
| if(!rs.next()) {
| throw new LookupException("Unable to find specified table:"+tbl);
| }
| String name;
| int count = 3;
| do {
| name = rs.getString(count);
| if(name.equals(tbl)) {
| table = new DbTable(name);
| readTableColumns(meta, table);
| break;
| }
| }while(rs.next());
| }finally {
| AppHelper.closeResultSet(rs);
| AppHelper.releaseConnection(con);
| }
| return table;
| }
|
| private void readTableColumns(DatabaseMetaData meta, DbTable table) throws SQLException {
| logger.info("entering readTableColumns");
| ResultSet columns = meta.getColumns(null, "%", table.getTableName(), "%");
| while (columns.next()) {
| String columnName = columns.getString("COLUMN_NAME");
| String datatype = columns.getString("TYPE_NAME");
| int datasize = columns.getInt("COLUMN_SIZE");
| int digits = columns.getInt("DECIMAL_DIGITS");
| int nullable = columns.getInt("NULLABLE");
|
| boolean isNull = (nullable == 1);
|
| DbColumn newColumn = new DbColumn(columnName, datatype, datasize, digits, isNull);
| table.addColumn(newColumn);
| }
| logger.info("leaving readTableColumns");
| }
View the original post : http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4023319#4023319
Reply to the post : http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=4023319
19Â years, 1Â month
[JBoss Seam] - Using the JPA delegate
by eirirlar
Hi, I wonder if I'm the only one who's encountered this when trying to use the JPA delegate when Hibernate is the underlying persitence provider.
Look at chapter 8.4 in the doc. It says:
| @In EntityManager entityManager;
|
| @Create
| public void init() {
| ( (Session) entityManager.getDelegate() ).enableFilter("currentVersions");
| }
>From my experience, entityManager.getDelegate() returns a org.hibernate.ejb.EntityManagerImpl, not a org.hibernate.Session. So the code in the example should be replaced by something like this:
| @In EntityManager entityManager;
|
| @Create
| public void init() {
| ( (Session) ((HibernateEntityManager)em.getDelegate()).getSession()).enableFilter("currentVersions");
| }
View the original post : http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4023308#4023308
Reply to the post : http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=4023308
19Â years, 1Â month
[JBoss Messaging] - Issues w/ JBoss Messging Cluster Environment when using Dura
by rpkavuri
I am trying to set up the JBoss cluster in two machines. Here are the steps I have followed to set up and test the examples -
1) Installed the JBoss4.0.5 on 2 machines by using the default partition name
2) Modified the config files to refer to our in house Oracle Database
3) Installed the jboss-messaging1.2.CR1 on both the machines
4) Modified/added the config files to refer in house Oracle Database
5) Started the servers
6) Verified that the JMS related Tables have created in Oracle Database or not. They are created.
6) Ran the examples on Node1 machine
- When both Nodes are up and running
- Queue and Topic examples ran well
- Getting exceptions while trying to run the other(Queue Failover, mdb etc.) examples.
- When I shut down the Node1 server
- None of the examples are running
7) Modifed jndi.properties file to set PORVIDER_URL parameter to 2 Nodes URLs on Node1 machine
- When both Nodes are up and running
- Queue and Topic examples ran well
- Getting exceptions while trying to run the other(Queue Failover, mdb etc.) examples.
- When I shut down the Node1 server
- Queue and Topic examples ran well
- Getting exceptions while trying to run the other(Queue Failover, mdb etc.) examples.
After the above steps, I have following questions -
1) Why is Auto-Failover is not working?
2) Is there something wrong w/ my cluster configuration?
3) Do the clients need to know about all the running clusters?
4) How do both the clusters know each other?
5) Is there any heartbeat mechanism b/w both the clusters?
6) How do I make one of the cluster as ACTIVE node and the other as INACTIVE?(Inactive one becomes only active when the current active one becomes unavailable)
Also I have written clients for both publisher and subscriber. We are planning to use durable subscriber. But I am unable to retrive any messages from my subscriber.
Here is the code -
|
| Publisher
|
| import javax.jms.JMSException;
| import javax.jms.Message;
| import javax.jms.MessageListener;
| import javax.jms.Topic;
| import javax.jms.TopicConnection;
| import javax.jms.TopicConnectionFactory;
| import javax.jms.TopicPublisher;
| import javax.jms.TopicSubscriber;
| import javax.jms.TopicSession;
| import javax.jms.TextMessage;
| import javax.jms.DeliveryMode;
| import javax.naming.Context;
| import javax.naming.InitialContext;
| import javax.naming.NamingException;
| import java.util.Hashtable;
| import javax.jms.MessageListener;
|
| /** A JMS client example program that sends a TextMessage to a Topic*/
|
| public class TopicSendClient{
|
| TopicConnection conn = null;
| TopicConnection conn1 = null;
|
| TopicSession session = null;
|
| Topic topic = null;
|
| String CLIENT_ID = "TopicClient";
|
| long MESSAGE_LIFESPAN = 1800000; //30 minutes
|
| public void setupPubSub() {
| System.out.println("setupPubSub()");
|
|
| // Initial environment with various properties
| Hashtable<Object, Object> env = new Hashtable<Object, Object>();
| env.put(Context.INITIAL_CONTEXT_FACTORY, "org.jnp.interfaces.NamingContextFactory");
| env.put(Context.PROVIDER_URL, "jnp://server1:1099,jnp://server2:1099");
| env.put(Context.URL_PKG_PREFIXES, "org.jboss.naming:org.jnp.interfaces");
|
| try{
| System.out.println("Before()");
| InitialContext iniCtx = new InitialContext(env);
|
| System.out.println("ConnectionFactory Not exists");
|
| //InitialContext iniCtx = new InitialContext();
| Object tmp = iniCtx.lookup("ConnectionFactory");
|
| System.out.println("ConnectionFactory exists");
|
| TopicConnectionFactory tcf = (TopicConnectionFactory) tmp;
|
| //topic = (Topic) iniCtx.lookup("topic/testDistributedTopic");
| topic = (Topic) iniCtx.lookup("topic/testTopic");
|
| System.out.println("TCF exists");
|
| conn = tcf.createTopicConnection();
| //conn1 = tcf.createTopicConnection();
|
| //conn.setClientID(CLIENT_ID);
|
| System.out.println("Topic testTopic exists");
|
| session = conn.createTopicSession(false, TopicSession.AUTO_ACKNOWLEDGE);
|
| conn.start();
| }catch(Exception e){
| System.out.println("TopicConnection Not started"+e.getMessage());
| e.printStackTrace();
| }
|
|
| }
|
|
| public void sendAsync(String text) throws JMSException, NamingException {
|
| System.out.println("Begin sendAsync");
|
| // Setup the pub/sub connection, session
| setupPubSub();
|
| // Send a text msg
| TopicPublisher send = session.createPublisher(topic);
|
|
| TextMessage tm = session.createTextMessage(text);
|
| //send.publish(tm);
| send.publish( tm, DeliveryMode.PERSISTENT, Message.DEFAULT_PRIORITY, -1 );
|
| System.out.println("sendAsync, sent text="+ tm.getText());
|
| send.close();
|
| System.out.println("End sendAsync");
|
| }
|
|
| public void stop() throws JMSException {
|
| conn.stop();
|
| session.close();
|
| conn.close();
|
| }
|
|
| public static void main(String args[]) throws Exception {
|
| System.out.println("Begin TopicSendClient, now="+System.currentTimeMillis());
|
| TopicSendClient client = new TopicSendClient();
|
| client.sendAsync("A text msg, now="+System.currentTimeMillis());
|
| client.stop();
|
| System.out.println("End TopicSendClient");
|
| System.exit(0);
|
| }
| }
|
| Subscriber
|
| import javax.jms.JMSException;
|
| import javax.jms.Message;
|
| import javax.jms.MessageListener;
|
| import javax.jms.Topic;
|
| import javax.jms.TopicConnection;
|
| import javax.jms.TopicConnectionFactory;
|
| import javax.jms.TopicPublisher;
|
| import javax.jms.TopicSubscriber;
|
| import javax.jms.TopicSession;
|
| import javax.jms.TextMessage;
|
| import javax.naming.Context;
|
| import javax.naming.InitialContext;
|
| import javax.naming.NamingException;
|
| import java.util.Hashtable;
|
| /** A JMS client example program that synchronously receives a message a Topic */
|
| public class TopicRecvClient {
|
| TopicConnection conn = null;
|
| TopicSession session = null;
|
| Topic topic = null;
|
| String CLIENT_ID = "guest";
|
| long MESSAGE_LIFESPAN = 1800000; //30 minutes
| //long MESSAGE_LIFESPAN = 5000;
|
|
| public void setupPubSub() throws JMSException, NamingException{
|
| // Initial environment with various properties
| Hashtable<Object, Object> env = new Hashtable<Object, Object>();
| env.put(Context.INITIAL_CONTEXT_FACTORY, "org.jnp.interfaces.NamingContextFactory");
| env.put(Context.PROVIDER_URL, "jnp://server1:1099,jnp://server2:1099");
| env.put(Context.URL_PKG_PREFIXES, "org.jboss.naming:org.jnp.interfaces");
| env.put (Context.SECURITY_PRINCIPAL, "guest");
| env.put (Context.SECURITY_CREDENTIALS, "guest");
| //env.put(Context.OBJECT_FACTORIES, "foo.bar.ObjFactory");
| //env.put("foo", "bar")
|
| InitialContext iniCtx = new InitialContext(env);
|
| Object tmp = iniCtx.lookup("ConnectionFactory");
|
| TopicConnectionFactory tcf = (TopicConnectionFactory) tmp;
|
| conn = tcf.createTopicConnection("guest","guest");
| //conn = tcf.createTopicConnection();
|
| topic = (Topic) iniCtx.lookup("topic/testTopic");
|
| //conn.setClientID(CLIENT_ID);
|
| session = conn.createTopicSession(false, TopicSession.AUTO_ACKNOWLEDGE);
|
| conn.start();
|
| }
|
|
| public void recvSync() throws JMSException, NamingException
| {
|
| System.out.println("Begin recvSync");
|
| // Setup the pub/sub connection, session
|
| setupPubSub();
|
| // Wait upto 5 seconds for the message
|
| //TopicSubscriber recv = session.createSubscriber(topic);
|
| TopicSubscriber recv = session.createDurableSubscriber(topic, "SampleSubscription");
|
|
| Message msg = recv.receive(5000);
|
| if( msg == null )
|
| System.out.println("Timed out waiting for msg");
|
| else
|
| System.out.println("TopicSubscriber.recv, msgt="+msg);
|
| }
|
|
| public void stop() throws JMSException
| {
|
| conn.stop();
|
| session.close();
|
| conn.close();
|
| }
|
| public static void main(String args[]) throws Exception
| {
|
| System.out.println("Begin TopicRecvClient, now="+System.currentTimeMillis());
|
| TopicRecvClient client = new TopicRecvClient();
|
|
| client.recvSync();
| client.stop();
|
| System.out.println("End TopicRecvClient");
|
| System.exit(0);
|
| }
| }
|
| Thanks!!!
| Rajendra
View the original post : http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4023304#4023304
Reply to the post : http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=4023304
19Â years, 1Â month