Sam Smoot

I have a service that accepts inline SOAP attachments, but a client who can only provide MTOM. Is there a standard conversion process or tool already in place for this or will we need to hammer it out ourselves? There is not a lot of flexability in either service, so we have to handle it externally.

Thank you for your time.

I am trying to create a communications manager for an odd environment and I am attempting to use pipes / channels for the "path". I am having a little trouble in understanding these in that, for each pipe, do I have to have a separate socket / port for it or can they all operate over a single port? As I stated, this is not a normal environment (ok, Mainframe) and the management of resources isn't as friendly as it is in a distributed / web environment.

Thanks for the help!
[ April 14, 2008: Message edited by: Sam Smoot ]

I need to be able to connect and run methods from an existing class that is running as a daemon process on a UNIX system. How do I issue commands / method calls from an external class to interact with the running process?

Thanks in advance.
[ July 13, 2007: Message edited by: Sam Smoot ]

I have a process that requires me to write to a file on an external system and does not generate output on the calling system. How do I execute / invoke the Runtime.getRuntime().exec(myCode); process to make this happen correctly? The command is running on a Unix based system, but the output is going to an IBM z/OS mainframe.

I can execute the "myCode" commands in the native Unix environment as a script and it sends the data to the z/OS side without a problem. I just need this to do this without external intervention (automated process).

Any / all help is greatly appreciated..

I need to know if it is at all possible to exend a class that is written in c/c++ and accessed by using JNI wrapper services with Java. I cannot touch the acutal source (c/c++) code.

Thanks.
Sam

Took some massaging, but I finally got it to work.. Originally, I was using Buffered Reader / file logic, so that is why it may look a little messy. I'm still cleaning it up, but this helped a lot.


private LinkedList parseISToLkedList(InputStream is){ java.io.DataInputStream din = new java.io.DataInputStream(is); LinkedList outList = new LinkedList(); try{ String line = null; while((line=din.readLine()) != null){ outList.add(line); } }catch(Exception ex){ ex.getMessage(); }finally{ try{ is.close(); }catch(Exception ex){} } return outList; } public LinkedList readJCLtxt(String infile, LinkedList inList) { // set up output string LinkedList outList = new LinkedList(); if(inList != null) outList = inList; // set up file information for connection & read; InputStream is = ClassLoader.getSystemResourceAsStream(infile); LinkedList tll = parseISToLkedList(is); Iterator tli = tll.iterator(); while(tli.hasNext()){ outList.add(tli.next()); } return outList; }

Oh, and I'm currently using the internal builder in NetBeans to create the .jar file, but I have used ANT as well.

Thanks again!
Sam
[ September 06, 2006: Message edited by: Sam Smoot ]

I guess what I'm looking for is what or where I define the resource, either genericaly or through Netbeans, so that as I develop and deploy, everything works the same. I need to make this as much of a single package "tool" as possible.

Thanks.
Sam

I am creating an application that requires some .txt files to be accessed during processing. Currently, they are in the root of my project directory structure because I can't access them from anywhere else. I know that I should be able to add them to the .jar file and still be able to access them, but I'm not sure which property, build, or resource file I need to modify to make the code in the project actually access the file without it being in the project's root directory.

I am currently using NetBeans 5.0 for this project. Any / all help is greatly appreciated.

Sam

I need to know what the actual definition (accepted descriptions?) of what an API actually needs to be and/or entails. I need to create access and controls into a legacy based system that has indirect access by java. If this is done right, this could become part of a commercial product, but I just need some advice / clarification on the subject so that I can proceed with MUCH caution.

Thanks in advance!

Sam

Thanks for the responses.. I haven't really had to code in a while, so I'm trying to catch back up. I'll let you know what I wind up with.

As a general review question: Won't the "new Date()" call cause a bunch of Date objects in memory? If so, when can they be expired to be collected by the garbage collector or would that really matter?

Thanks again.
Sam
[ August 21, 2006: Message edited by: Sam Smoot ]

This is probably not advanced enough for this forum, but..

I'm trying to get a "clock" to work out in java (actually as a JSP, but for now, in Java). When I execute the following code, I get the same time over and over, but I (thought) am reloading the time value at every iteration of the loop...

import java.text.*; import java.util.Date; public class javaClock { /** Creates a new instance of javaClock */ public javaClock() { } private void clock(){ Date d = new Date(); SimpleDateFormat df = new SimpleDateFormat("HH:mm:ss"); // time loop while(true){ d.getTime(); // this gets reloaded? System.out.print(df.format(d)); for(int i=0;i<100;i++){ for(int j=0;j<1000;j++){ for(int k=0;k<10000;k++){ } } } } } public static void main(String[] args){ javaClock jc = new javaClock(); jc.clock(); } }


What am I missing?

Thanks in advance.

You might try this...

Javascript Q-A

Well, it kinda works, but now the server won't reuse the threads.... How do you make the server recycle the threads on it's end?


/** * Time-of-day server listening to port 6013. * * To simulate the server delay, sleep a while before generating the date. * */ import java.net.*; import java.io.*; import java.util.*; import java.util.concurrent.*; public class DateServer { public static void main(String[] args) throws IOException { NetworkService nws = new NetworkService(6013, 5); nws.serve(5); } } class NetworkService { private final ServerSocket serverSocket; private final ExecutorService pool; public NetworkService(int port, int poolSize) throws IOException { serverSocket = new ServerSocket(port); pool = Executors.newFixedThreadPool(poolSize); } public void serve(int poolNum) { try { for (int i = 0; i < poolNum; i++) { pool.execute(new Handler(serverSocket.accept())); System.out.println("Server Thread " + (i+1)); } } catch (IOException IOE) { pool.shutdown(); } } class Handler implements Runnable { private final Socket socket; Handler(Socket socket) { this.socket = socket; } public void run() { // read service request Socket client = new Socket(); try{ client = serverSocket.accept(); // we have a connection PrintWriter pout = new PrintWriter(client.getOutputStream(), true); // Sleep a while // int aWhile = (int) (java.lang.Math.random()*1000); // java.lang.Thread.sleep(aWhile); // write the Date to the socket pout.println(new Date().toString()); pout.close(); client.close(); } catch (Exception err) { System.err.println(err); } } } }

=================

/** * Client program requesting current date from server. * * */ import java.net.*; import java.io.*; import java.util.concurrent.*; public class DateClient { public static void main(String[] args) throws IOException { ClientSvc csvc = new ClientSvc("127.0.0.1", 6013, 50); csvc.ClientCall(6013,50); } } class ClientSvc{ private final Socket socket; private final ExecutorService clientPool; public ClientSvc(String addr, int port, int size) throws IOException{ socket = new Socket(addr, port); clientPool = Executors.newFixedThreadPool(size); } public void ClientCall(int port, int nThread) { try { for (int i = 0; i < nThread; i++) { clientPool.execute(new ClientHandler(socket)); System.out.println(" Client Thread " + (i+1)); } } catch (Exception ioe) { clientPool.shutdown(); } } } class ClientHandler implements Runnable{ private final Socket socket; ClientHandler(Socket socket){ this.socket = socket; } public void run() { InputStream in = null; BufferedReader bin = null; Socket sock = null; try { sock = new Socket("127.0.0.1", 6013); in = sock.getInputStream(); bin = new BufferedReader(new InputStreamReader(in)); String line; while ((line = bin.readLine()) != null) System.out.println("client result: " + line ); }catch (Exception ioe) { System.err.println(ioe); } } }
[ March 09, 2006: Message edited by: Sam Smoot ]

I'm assuming you are talking about the client part. I'm gonna give it a try and see if it'll work (probably will, I'm really too old for this...)


Thanks for the help!

Sam

First, I will admit up front that this is a homework assignment. I need some guideance, but I am not looking for a final solution. However, I have no other resource at this time to eyeball this with me to see what is missing, so any good nudge will be greatly appreciated.

I have a class DateServer that is supposed to generate multiple threads (5) for a client to access. This is what I have, but...

/** * Time-of-day server listening to port 6013. * * To simulate the server delay, sleep a while before generating the date. * */ import java.net.*; import java.io.*; import java.util.*; import java.util.concurrent.*; public class DateServer { public static void main(String[] args) throws IOException { NetworkService nws = new NetworkService(6013, 5); nws.serve(); } } class NetworkService { private final ServerSocket serverSocket; private final ExecutorService pool; public NetworkService(int port, int poolSize) throws IOException { serverSocket = new ServerSocket(port); pool = Executors.newFixedThreadPool(poolSize); } public void serve() { try { for (int i = 0; i < 5; i++) { pool.execute(new Handler(serverSocket.accept())); System.out.println("looping"); } } catch (IOException IOE) { pool.shutdown(); } } class Handler implements Runnable { private final Socket socket; Handler(Socket socket) { this.socket = socket; } public void run() { // read service request Socket client = new Socket(); try{ client = serverSocket.accept(); System.out.println("client = " + client); // we have a connection PrintWriter pout = new PrintWriter(client.getOutputStream(), true); // Sleep a while int aWhile = (int) (java.lang.Math.random()*5000); java.lang.Thread.sleep(aWhile); // write the Date to the socket pout.println(new Date().toString()); pout.close(); client.close(); } catch (Exception err) { System.err.println(err); } } } }

I then have a client (DateClient) that is currently only a single thread, but I also have to modify it to create 50 threads to act like there are multiple request accessing the DateServer.

/** * Client program requesting current date from server. * * */ import java.net.*; import java.io.*; public class DateClient { public static void main(String[] args) throws IOException { InputStream in = null; BufferedReader bin = null; Socket sock = null; try { sock = new Socket("127.0.0.1",6013); in = sock.getInputStream(); bin = new BufferedReader(new InputStreamReader(in)); String line; while( (line = bin.readLine()) != null) System.out.println("client " + line); }catch(IOException ioe){ System.err.println(ioe); } finally { sock.close(); } } }

Originally, I had a loop around the try block for 50 passes, and it worked on the original server, but only 1 at a time.

Again, I'm not looking for the direct solution, but a good hint in the right direction is greatly appreciated.