I see one error in your Activator.
You should store the ServiceRegistration that you get from
registerService in a variable of the activator.
In the stop method you should then call unregister on the
ServiceRegistration. The call to ungetService is not suitable for the
serviceprovider but only
for the consumer.
This is not the problem you observe though. I assume that one of the
"new" calls to either CBridgeImpl or EchoService does not return. The
activator is called synchronously by
the OSGi framework. It is very important that it does not "hang" or
consume too much time as this will affect the whole framework. Can you
also post the content of these classes?
The other question is if you need to register an OSGi service at all. If
you only want to open a network port then you can just do this from the
start method. OSGi services only make sense if there is also a consumer
of the service inside the OSGi framework.
Christian
Am 11.02.2012 10:57, schrieb rcbandit2:
I register the Java network server as service. When I try to deploy the OSGI
bundle with the java server Glassfish freezes. But I can successfully make a
connection with the java network client. It seems that when I try to deploy
the OSGI bundle there is a infinite loop. How I can solve the problem? This
is the code of the Activator:
package org.DX_57.osgi.CB_27.impl;
import java.util.Properties;
import org.DX_57.osgi.CB_27.api.CBridge;
import org.osgi.framework.BundleActivator;
import org.osgi.framework.BundleContext;
public class CBridgeApp implements BundleActivator {
public void start(BundleContext bc) throws Exception {
bc.registerService(CBridge.class.getName(), new CBridgeImpl(), new
Properties());
bc.registerService(EchoServer.class.getName(), new EchoServer(), new
Properties());
}
public void stop(BundleContext bc) throws Exception {
bc.ungetService(bc.getServiceReference(CBridge.class.getName()));
}
}
rcbandit2 wrote:
This is my simple example of OSGI bundle:
http://www.2shared.com/file/h6lFjppY/CB_27.html
Where I have to put the source code of the java network server in order to
work?
nfndx wrote:
It does not seem like you need your network server to be a osgi service.
So
if you just need your network server to be started then create a osgi
bundle. Also create an activator for this bundle( remember to set this
activator in the manifest) . In the start method if the activator you
should be able to start your network server
Hope that helps
Regards
Ivanhoe
On Feb 10, 2012 5:32 PM, "rcbandit2"<[email protected]> wrote:
Any ideas or reply?
rcbandit2 wrote:
Hi,
I created this Java network server:
import java.net.*;
import java.io.*;
public class EchoServer
{
ServerSocket m_ServerSocket;
public EchoServer()
{
try
{
// Create the server socket.
m_ServerSocket = new ServerSocket(12111);
}
catch(IOException ioe)
{
System.out.println("Could not create server socket at 12111.
Quitting.");
System.exit(-1);
}
System.out.println("Listening for clients on 12111...");
// Successfully created Server Socket. Now wait for connections.
int id = 0;
while(true)
{
try
{
// Accept incoming connections.
Socket clientSocket = m_ServerSocket.accept();
ClientServiceThread cliThread = new ClientServiceThread(clientSocket,
id++);
cliThread.start();
}
catch(IOException ioe)
{
System.out.println("Exception encountered on accept. Ignoring. Stack
Trace
:");
ioe.printStackTrace();
}
}
}
public static void main (String[] args)
{
new EchoServer();
}
class ClientServiceThread extends Thread
{
Socket m_clientSocket;
int m_clientID = -1;
boolean m_bRunThread = true;
ClientServiceThread(Socket s, int clientID)
{
m_clientSocket = s;
m_clientID = clientID;
}
public void run()
{
// Obtain the input stream and the output stream for the socket
// A good practice is to encapsulate them with a BufferedReader
// and a PrintWriter as shown below.
BufferedReader in = null;
PrintWriter out = null;
// Print out details of this connection
System.out.println("Accepted Client : ID - " + m_clientID + " :
Address -
" +
m_clientSocket.getInetAddress().getHostName());
try
{
in = new BufferedReader(new
InputStreamReader(m_clientSocket.getInputStream()));
out = new PrintWriter(new
OutputStreamWriter(m_clientSocket.getOutputStream()));
// At this point, we can read for input and reply with appropriate
output.
// Run in a loop until m_bRunThread is set to false
while(m_bRunThread)
{
// read incoming stream
String clientCommand = in.readLine();
System.out.println("Client Says :" + clientCommand);
if(clientCommand.equalsIgnoreCase("quit"))
{
// Special command. Quit this thread
m_bRunThread = false;
System.out.print("Stopping client thread for client : " + m_clientID);
}
else
{
// Echo it back to the client.
out.println(clientCommand);
out.flush();
}
}
}
catch(Exception e)
{
e.printStackTrace();
}
finally
{
// Clean up
try
{
in.close();
out.close();
m_clientSocket.close();
System.out.println("...Stopped");
}
catch(IOException ioe)
{
ioe.printStackTrace();
}
}
}
}
}
I want to insert this code into OSGI bundle. At the moment I don't
have
configured Glassfish with datasource to test the bundle. What I have
to
do
in order to configure the Java server to listen for incomming
connections
when I deploy it on Glassfish server?
Do I need to add somenthing into the OSGI bundle activator to make the
Java server listen for incomming connections?
Best Wishes
--
View this message in context:
http://old.nabble.com/How-to-add-Java-network-server-into-OSGI-bundle-tp33295152p33301156.html
Sent from the Apache Felix - Users mailing list archive at Nabble.com.
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
--
Christian Schneider
http://www.liquid-reality.de
Open Source Architect
Talend Application Integration Division http://www.talend.com
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
