<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.0 Transitional//EN">
<html>
<body link="#355491" alink="#4262a1" vlink="#355491" style="background: #e2e2e2; margin: 0; padding: 20px;">
<div>
<table cellpadding="0" bgcolor="#FFFFFF" border="0" cellspacing="0" style="border: 1px solid #dadada; margin-bottom: 30px; width: 100%; -moz-border-radius: 6px; -webkit-border-radius: 6px;">
<tbody>
<tr>
<td>
<table border="0" cellpadding="0" cellspacing="0" bgcolor="#FFFFFF" style="border: solid 2px #ccc; background: #dadada; width: 100%; -moz-border-radius: 6px; -webkit-border-radius: 6px;">
<tbody>
<tr>
<td bgcolor="#000000" valign="middle" height="58px" style="border-bottom: 1px solid #ccc; padding: 20px; -moz-border-radius-topleft: 3px; -moz-border-radius-topright: 3px; -webkit-border-top-right-radius: 5px; -webkit-border-top-left-radius: 5px;">
<h1 style="color: #333333; font: bold 22px Arial, Helvetica, sans-serif; margin: 0; display: block !important;">
<!-- To have a header image/logo replace the name below with your img tag -->
<!-- Email clients will render the images when the message is read so any image -->
<!-- must be made available on a public server, so that all recipients can load the image. -->
<a href="https://community.jboss.org/index.jspa" style="text-decoration: none; color: #E1E1E1">JBoss Community</a></h1>
</td>
</tr>
<tr>
<td bgcolor="#FFFFFF" style="font: normal 12px Arial, Helvetica, sans-serif; color:#333333; padding: 20px; -moz-border-radius-bottomleft: 4px; -moz-border-radius-bottomright: 4px; -webkit-border-bottom-right-radius: 5px; -webkit-border-bottom-left-radius: 5px;"><h3 style="margin: 10px 0 5px; font-size: 17px; font-weight: normal;">
Re: View payload and header data in the table
</h3>
<span style="margin-bottom: 10px;">
created by <a href="https://community.jboss.org/people/pasanperera">Pasan Perera</a> in <i>JBoss Messaging</i> - <a href="https://community.jboss.org/message/727718#727718">View the full discussion</a>
</span>
<hr style="margin: 20px 0; border: none; background-color: #dadada; height: 1px;">
<div class="jive-rendered-content"><p>If you want to get the javax.jms.Message (or any other message types that you have added to the queue) the following will help.</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>Note that most of the source is copied from JDBCPersistenceManager class in package "jboss-messaging-1.4.2.GA-SP1</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>Write a query to retrieve all columns from JBM_MSG</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>    if (rs.next())</p><p>    {</p><p>      long messageId = rs.getLong("MESSAGE_ID");</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>      boolean reliable = rs.getString("RELIABLE").equals("Y");</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>      long expiration = rs.getLong("EXPIRATION");</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>      long timestamp = rs.getLong("TIMESTAMP");</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>      byte priority = rs.getByte("PRIORITY");</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>      byte[] bytes = getBytes(rs, "HEADERS");</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>      HashMap headers = bytesToMap(bytes);</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>      byte[] payload = getBytes(rs, "PAYLOAD");</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>      byte type = rs.getByte("TYPE");</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>  MapMessage m = (MapMessage)MessageFactory.createMessage(messageId, reliable, expiration, timestamp, priority, headers, payload,</p><p>          type);</p><p>}</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>  private boolean usingBinaryStream = true;</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>  protected byte[] getBytes(ResultSet rs, String column) throws Exception</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>  {</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>    if (usingBinaryStream)</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>    {</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>      // Get the bytes using a binary stream - likely to be better for large</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>      // byte[]</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>      InputStream is = null;</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>      ByteArrayOutputStream os = null;</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>      final int BUFFER_SIZE = 4096;</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>      try</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>      {</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>        InputStream i = rs.getBinaryStream(column);</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>        if (i == null)</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>        {</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>          return null;</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>        }</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>        is = new BufferedInputStream(rs.getBinaryStream(column), BUFFER_SIZE);</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>        os = new ByteArrayOutputStream(BUFFER_SIZE);</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>        int b;</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>        while ((b = is.read()) != -1)</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>        {</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>          os.write(b);</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>        }</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>        return os.toByteArray();</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>      }</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>      finally</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>      {</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>        if (is != null)</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>        {</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>          is.close();</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>        }</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>        if (os != null)</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>        {</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>          os.close();</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>        }</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>      }</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>    }</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>    else</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>    {</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>      // Get the bytes using getBytes() - better for smaller byte[]</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>      return getVarBinaryColumn(rs, column);</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>    }</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>  }</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>  protected byte[] getVarBinaryColumn(ResultSet rs, String column) throws Exception</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>  {</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>    byte[] bytes = rs.getBytes(column);</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>    if (true)</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>    {</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>      // Get rid of the trailing byte</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p><span>      // </span><a class="jive-link-external-small" href="http://jira.jboss.org/jira/browse/JBMESSAGING-825" target="_blank">http://jira.jboss.org/jira/browse/JBMESSAGING-825</a></p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>      byte[] newBytes = new byte[bytes.length - 1];</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>      System.arraycopy(bytes, 0, newBytes, 0, bytes.length - 1);</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>      bytes = newBytes;</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>    }</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>    return bytes;</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>  }</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>  protected HashMap bytesToMap(byte[] bytes) throws Exception</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>  {</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>     if (bytes == null) { return new HashMap(); }</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>     ByteArrayInputStream bis = new ByteArrayInputStream(bytes);</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>     DataInputStream dais = new DataInputStream(bis);</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>     HashMap map = StreamUtils.readMap(dais, true);</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>     dais.close();</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>     return map;</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>  }</p></div>
<div style="background-color: #f4f4f4; padding: 10px; margin-top: 20px;">
<p style="margin: 0;">Reply to this message by <a href="https://community.jboss.org/message/727718#727718">going to Community</a></p>
<p style="margin: 0;">Start a new discussion in JBoss Messaging at <a href="https://community.jboss.org/choose-container!input.jspa?contentType=1&containerType=14&container=2042">Community</a></p>
</div></td>
</tr>
</tbody>
</table>
</td>
</tr>
</tbody>
</table>
</div>
</body>
</html>