|
|||||||||
ÀüÀÇ Å¬·¡½º ´ÙÀ½ÀÇ Å¬·¡½º | ÇÁ·¹ÀÓ ÀÖ¾î ÇÁ·¹ÀÓ ¾øÀ½ | ||||||||
°³¿ä: ³»ºÎ Ŭ·¡½º | Çʵå | constructor¡¡ ¡¡ | ¸Þ¼Òµå | »ó¼¼: Çʵå | constructor¡¡ ¡¡ | ¸Þ¼Òµå |
Session
¿ÀºêÁ§Æ®´Â, ¸Þ¼¼ÁöÀÇ »ý¼º ¹× 󸮿ëÀÇ ´ÜÀÏ thread ¹®¸ÆÀÔ´Ï´Ù. ÀÌ ¿ÀºêÁ§Æ®´Â, ÇÁ·Î¹ÙÀÌ´õ ¸®¼Ò½º¸¦ Java °¡»ó ¸Ó½Å (JVM)ÀÇ ¿ÜºÎ¿¡ ÇÒ´çÇÏ´Â °ÍÀÌ °¡´ÉÇÕ´Ï´Ù¸¸, °æ·® JMS ¿ÀºêÁ§Æ®·Î °£ÁÖÇØÁý´Ï´Ù.
¼¼¼Ç¿¡´Â, ´ÙÀ½°ú °°Àº »ç¿ë ¸ñÀûÀÌ ÀÖ½À´Ï´Ù.
¼¼¼ÇÀº, º¹¼öÀÇ ¸ä¼¼ÀÌÁöÇÁ·Îµà»ç ¹× ÄÁ½´¸Ó(consumer)¸¦ ÀÛ¼ºÇÒ ¼ö ÀÖ½À´Ï´Ù.
ÀüÇüÀûÀÎ »ç¿ë ¹æ¹ýÀº, ¸Þ¼¼Áö°¡ µµÂøÇÒ ¶§±îÁö, µ¿±â MessageConsumer
»ó¿¡¼ thread¿¡ ºí·ÏÀ» ½ÇÇà½ÃŰ´Â °ÍÀÔ´Ï´Ù. ±× ÈÄ, thread´Â Session
ÀÇ MessageProducer
¸¦ 1 °³ ÀÌ»ó »ç¿ëÇÒ ¼ö ÀÖ½À´Ï´Ù.
1 °³ÀÇ thread°¡ ¸Þ¼¼Áö¸¦ »ý¼ºÇØ, ´Ù¸¥ thread°¡ ±×°ÍÀ» ó¸®ÇÏ´Â °ÍÀ» Ŭ¶óÀÌ¾ðÆ®°¡ ¹Ù¶ó´Â °æ¿ì, Ŭ¶óÀÌ¾ðÆ®´Â, »ý¼ºÇÏ´Â thread¿ëÀ¸·Î º°°³ÀÇ ¼¼¼ÇÀ» »ç¿ëÇÒ Çʿ䰡 ÀÖ½À´Ï´Ù.
Á¢¼ÓÀÌ °³½ÃµÇ¸é(ÀÚ), µî·ÏÀ» ¸¶Ä£ ¸Þ¼¼Áö ûÃëÀÚ¸¦ 1 °³ ÀÌ»ó º¸°ü À¯ÁöÇÏ´Â ¼¼¼ÇÀº ¸ðµÎ, ¸Þ¼¼Áö¸¦ Àü´ÞÇÏ´Â Á¦¾î thread Àü¿ëÀÌ µË´Ï´Ù. Ŭ¶óÀÌ¾ðÆ® Äڵ尡 ÀÌ ¼¼¼Ç ¶Ç´Â ´Ù¸¥ Á¦¾î thread·ÎºÎÅÍÀÇ ±¸¼º ¿ÀºêÁ§Æ®¸¦ »ç¿ë ÇØ¼´Â ¾ÈµË´Ï´Ù. À¯ÀÏÇÑ ¿¹¿Ü´Â, ¼¼¼Ç ¶Ç´Â Á¢¼ÓÀÇ close
¸Þ¼Òµå¸¦ »ç¿ëÇÏ´Â °æ¿ìÀÔ´Ï´Ù.
´ëºÎºÐÀÇ Å¬¶óÀÌ¾ðÆ®´Â, ÀÛ¾÷À» ¼¼¼Ç¿¡ ¿ëÀÌÇÏ°Ô ±¸ºÐÈÇÒ ¼ö ÀÖÀ» °ÍÀÔ´Ï´Ù. ÀÌ ¸ðµ¨À» »ç¿ëÇÏ´Â °ÍÀ¸·Î½á, Ŭ¶óÀÌ¾ðÆ®´Â, concurrent processingÀÇ Çʿ伺¿¡ ¸ÂÃß¾î °£´ÜÇÏ°í ¼¼È÷ ¸Þ¼¼Áö 󸮸¦ º¹ÀâÈ ÇØ °¥ ¼ö°¡ ÀÖ½À´Ï´Ù.
close
¸Þ¼Òµå´Â, ´Ù¸¥ ¼¼¼Ç ¸Þ¼Òµå°¡ ´Ù¸¥ thread·Î ½ÇÇàÁß¿¡, È£ÃâÇØ °¡´ÉÇÑ À¯ÀÏÇÑ ¼¼¼Ç ¸Þ¼ÒµåÀÔ´Ï´Ù.
¼¼¼ÇÀº, Æ®·£Àè¼Ç(transaction) ½ÇÇà½Ã·Î ÁöÁ¤ÇÒ ¼ö ÀÖ½À´Ï´Ù. Æ®·£Àè¼Ç(transaction) 󸮵Ǵ °¢ ¼¼¼ÇÀº, 1 Á¶ÀÇ Æ®·£Àè¼Ç(transaction)¸¦ ¼Æ÷Æ®ÇÕ´Ï´Ù. °¢ Æ®·£Àè¼Ç(transaction)´Â, ¸Þ¼¼Áö ¼Û½Å ¼¼Æ® ¹× ¸Þ¼¼Áö ¼ö½Å ¼¼Æ®¸¦ ±×·ìÈ ÇØ, ºÒ°¡ºÐÀÎ ÀÛ¾÷ ´ÜÀ§·Î ÇÕ´Ï´Ù. ½ÇÁ¦ÀÇ °÷, Æ®·£Àè¼Ç(transaction)´Â ¼¼¼ÇÀÇ ÀÔ·Â ¸Þ¼¼Áö ½Ã³Á¹° ¹× Ãâ·Â ¸Þ¼¼Áö ½Ã³Á¹°À» ºÒ°¡ºÐÀÎ 1 Á¶ÀÇ ´ÜÀ§¿¡ Æí¼ºÇÕ´Ï´Ù. Æ®·£Àè¼Ç(transaction)°¡ À§Å¹µÇ¸é(ÀÚ), ºÒ°¡ºÐÀÎ ÀÔ·Â ´ÜÀ§°¡ È®ÀÎ ÀÀ´äµÇ¾î °ü·ÃÁöÀ» ¼ö ÀÖ¾ú´ø ºÒ°¡ºÐÀÎ Ãâ·Â ´ÜÀ§°¡ ¼Û½ÅµË´Ï´Ù. Æ®·£Àè¼Ç(transaction)ÀÇ ·Ñ¹é(rollback)ÀÌ ½ÇÇàµÇ¸é(ÀÚ), Æ®·£Àè¼Ç(transaction)ÀÇ ¼Û½Å ¸Þ¼¼Áö°¡ ÆÄ±âµÇ¾î ¼¼¼ÇÀÇ ÀÔ·ÂÀÌ ÀÚµ¿ÀûÀ¸·Î º¹¿øµË´Ï´Ù.
Æ®·£Àè¼Ç(transaction)ÀÇ ÀÔ·Â ¹× Ãâ·Â ´ÜÀ§ÀÇ ³»¿ëÀº, ¼¼¼ÇÀÇ ÇöÇà Æ®·£Àè¼Ç(transaction)³»¿¡¼ »ý¼º ¹× ó¸®µÈ ¸Þ¼¼ÁöÀÔ´Ï´Ù.
Æ®·£Àè¼Ç(transaction)´Â, ¼¼¼ÇÀÇ commit
¸Þ¼Òµå ¶Ç´Â rollback
¸Þ¼Òµå¸¦ »ç¿ëÇØ ¿Ï·áµË´Ï´Ù. ¼¼¼ÇÀÇ ÇöÇà Æ®·£Àè¼Ç(transaction)°¡ ¿Ï·áÇϸé(ÀÚ), ÀÚµ¿ÀûÀ¸·Î ´ÙÀ½ÀÇ Æ®·£Àè¼Ç(transaction)°¡ °³½ÃµË´Ï´Ù. ±× °á°ú, Æ®·£Àè¼Ç(transaction) 󸮵Ǵ ¼¼¼ÇÀº Ç×»ó ÇöÇàÀÇ Æ®·£Àè¼Ç(transaction)¸¦ º¸°ü À¯ÁöÇØ, ±× ³»ºÎ¿¡¼ ÀÛ¾÷À» ÇÕ´Ï´Ù.
Java Transaction Service (JTS) ¶Ç´Â ´Ù¸¥ Æ®·£Àè¼Ç(transaction) ¸ð´ÏÅ͸¦ »ç¿ëÇØ, ¼¼¼ÇÀÇ Æ®·£Àè¼Ç(transaction)¸¦ ´Ù¸¥ ¸®¼Ò½º (µ¥ÀÌŸº£À̽º, ´Ù¸¥ JMS ¼¼¼Çµî)¿Í °áÇÕÇÒ ¼ö ÀÖ½À´Ï´Ù. Java ºÐ»ê Æ®·£Àè¼Ç(transaction)´Â Java Transaction API (JTA)¸¦ °³ÀÔ½ÃÄÑ Á¦¾îµÇ±â (À§ÇØ)¶§¹®¿¡, ÀÌ ¹®¸Æ³»¿¡¼ ¼¼¼ÇÀÇ commit
¹× rollback
¸Þ¼Òµå¸¦ »ç¿ëÇÏ´Â °ÍÀº ±ÝÁöµÇ°í ÀÖ½À´Ï´Ù.
JMS API ¿¡¼´Â, JTA ÀÇ ¼Æ÷Æ®´Â ¿ä±¸µÇ°í ÀÖÁö ¾Ê½À´Ï´Ù. ´Ù¸¸, ÇÁ·Î¹ÙÀÌ´õ°¡ ÀÌ ¼Æ÷Æ®¸¦ Á¦°øÇÏ´Â ¹æ¹ýÀº Á¤Àǵǰí ÀÖ½À´Ï´Ù.
JMS Ŭ¶óÀÌ¾ðÆ®°¡ ºÐ»ê Æ®·£Àè¼Ç(transaction)¸¦ Á÷Á¢ ¼Æ÷Æ®ÇÏ´Â Àϵµ °¡´ÉÇÕ´Ï´Ù¸¸, ´Ù¼öÀÇ JMS Ŭ¶óÀÌ¾ðÆ®°¡ À̰ÍÀ» ¼Æ÷Æ®ÇÏ´Â °ÍÀº »ý°¢µÇÁö ¾Ê½À´Ï´Ù. JMS API ³»¿¡¼ÀÇ JTA ¼Æ÷Æ®´Â, JMS API ¸¦ ¾îÇø®ÄÉÀÌ¼Ç ¼¹ö Á¦Ç°¿¡ ÅëÇÕÇÏ´Â ½Ã½ºÅÛ º¥´õ¸¦ ´ë»óÀ¸·Î Çϰí ÀÖ½À´Ï´Ù.
QueueSession
,
TopicSession
,
XASession
ÇʵåÀÇ °³¿ä | |
static int |
AUTO_ACKNOWLEDGE
ÀÌ È®ÀÎ ÀÀ´ä ¸ðµå¿¡¼´Â, ¼¼¼ÇÀÌ receive ÀÇ È£Ãâ·ÎºÎÅÍÀÇ º¹±Í¿¡ ¼º°øÇÏ´ÂÁö, ¸Þ¼¼Áö¸¦ ó¸®Çϱâ À§Çؼ ¼¼¼ÇÀÌ È£ÃâÇÑ ¸Þ¼¼Áö ûÃëÀÚ°¡ º¹±Í¿¡ ¼º°øÇϸé(ÀÚ), ¼¼¼ÇÀº Ŭ¶óÀ̾ðÆ®ÀÇ ¸Þ¼¼Áö ¼ö½ÅÀ» ÀÚµ¿ÀûÀ¸·Î È®ÀÎ ÀÀ´äÇÕ´Ï´Ù. |
static int |
CLIENT_ACKNOWLEDGE
ÀÌ È®ÀÎ ÀÀ´ä ¸ðµå¿¡¼´Â, Ŭ¶óÀÌ¾ðÆ®´Â, ¸Þ¼¼ÁöÀÇ acknowledge ¸Þ¼Òµå¸¦ È£ÃâÇØ ó¸®ÇÊ º¸°íÀÇ ¸Þ¼¼Áö¸¦ È®ÀÎ ÀÀ´äÇÕ´Ï´Ù. |
static int |
DUPS_OK_ACKNOWLEDGE
ÀÌ È®ÀÎ ÀÀ´ä ¸ðµå´Â, ¼¼¼Ç¿¡ ´ëÇØ, ¸Þ¼¼Áö Àü´ÞÀÇ Áö¿¬ È®ÀÎ ÀÀ´äÀ» Áö½ÃÇÕ´Ï´Ù. |
¸Þ¼ÒµåÀÇ °³¿ä | |
void |
close ()
¼¼¼ÇÀ» ´Ý½À´Ï´Ù. |
void |
commit ()
ÀÌ Æ®·£Àè¼Ç(transaction)·Î ½ÇÇàµÈ ¸Þ¼¼Áö¸¦ ¸ðµÎ À§Å¹ÇØ, ¼³Á¤ÁßÀÇ ¶ôÀ» ¸ðµÎ ÇØ¹æÇÕ´Ï´Ù. |
BytesMessage |
createBytesMessage ()
BytesMessage ¿ÀºêÁ§Æ®¸¦ ÀÛ¼ºÇÕ´Ï´Ù. |
MapMessage |
createMapMessage ()
MapMessage ¿ÀºêÁ§Æ®¸¦ ÀÛ¼ºÇÕ´Ï´Ù. |
Message |
createMessage ()
Message ¿ÀºêÁ§Æ®¸¦ ÀÛ¼ºÇÕ´Ï´Ù. |
ObjectMessage |
createObjectMessage ()
ObjectMessage ¿ÀºêÁ§Æ®¸¦ ÀÛ¼ºÇÕ´Ï´Ù. |
ObjectMessage |
createObjectMessage (java.io.Serializable object)
ÃʱâÈ ³¡³ ObjectMessage ¿ÀºêÁ§Æ®¸¦ ÀÛ¼ºÇÕ´Ï´Ù. |
StreamMessage |
createStreamMessage ()
StreamMessage ¿ÀºêÁ§Æ®¸¦ ÀÛ¼ºÇÕ´Ï´Ù. |
TextMessage |
createTextMessage ()
TextMessage ¿ÀºêÁ§Æ®¸¦ ÀÛ¼ºÇÕ´Ï´Ù. |
TextMessage |
createTextMessage (java.lang.String text)
ÃʱâÈ ³¡³ TextMessage ¿ÀºêÁ§Æ®¸¦ ÀÛ¼ºÇÕ´Ï´Ù. |
MessageListener |
getMessageListener ()
¼¼¼ÇÀÇ ½Äº°µÈ ¸Þ¼¼Áö ûÃëÀÚ¸¦ µ¹·ÁÁÝ´Ï´Ù (¿É¼Ç). |
boolean |
getTransacted ()
¼¼¼ÇÀÌ Æ®·£Àè¼Ç(transaction) ¸ðµåÀÎÁö ¾î¶²Áö¸¦ ³ªÅ¸³À´Ï´Ù. |
void |
recover ()
ÀÌ ¼¼¼Ç³»ÀÇ ¸Þ¼¼Áö Àü´ÞÀ» Á¤ÁöÇØ, °¡Àå ³°Àº ¹ÌÈ®ÀÎ ÀÀ´äÀÇ ¸Þ¼¼Áö¸¦ »ç¿ëÇØ ¸Þ¼¼Áö Àü´ÞÀ» Àç°³ÇÕ´Ï´Ù. |
void |
rollback ()
ÀÌ Æ®·£Àè¼Ç(transaction)·Î ½ÇÇàµÈ ¸Þ¼¼Áö¸¦ ¸ðµÎ ·Ñ¹é(rollback) ÇØ, ¼³Á¤ÁßÀÇ ¶ôÀ» ¸ðµÎ ÇØ¹æÇÕ´Ï´Ù. |
void |
run ()
Åë»óÀÇ JMS Ŭ¶óÀÌ¾ðÆ®°¡ ¾Æ´Ï°í, Application Server ¿¡¼ÀÇ »ç¿ë¸¸À» ¸ñÀûÀ¸·Î ÇÑ ¿É¼Ç Á¶ÀÛÀÔ´Ï´Ù. |
void |
setMessageListener (MessageListener listener)
¼¼¼ÇÀÇ ½Äº° ¸Þ¼¼Áö ûÃëÀÚ¸¦ ¼³Á¤ÇÕ´Ï´Ù (¿É¼Ç). |
ÇʵåÀÇ »ó¼¼ |
public static final int AUTO_ACKNOWLEDGE
receive
ÀÇ È£Ãâ·ÎºÎÅÍÀÇ º¹±Í¿¡ ¼º°øÇÏ´ÂÁö, ¸Þ¼¼Áö¸¦ ó¸®Çϱâ À§Çؼ ¼¼¼ÇÀÌ È£ÃâÇÑ ¸Þ¼¼Áö ûÃëÀÚ°¡ º¹±Í¿¡ ¼º°øÇϸé(ÀÚ), ¼¼¼ÇÀº Ŭ¶óÀ̾ðÆ®ÀÇ ¸Þ¼¼Áö ¼ö½ÅÀ» ÀÚµ¿ÀûÀ¸·Î È®ÀÎ ÀÀ´äÇÕ´Ï´Ù. public static final int CLIENT_ACKNOWLEDGE
acknowledge
¸Þ¼Òµå¸¦ È£ÃâÇØ ó¸®ÇÊ º¸°íÀÇ ¸Þ¼¼Áö¸¦ È®ÀÎ ÀÀ´äÇÕ´Ï´Ù. ó¸®ÇÊ º¸°íÀÇ ¸Þ¼¼Áö¸¦ È®ÀÎ ÀÀ´äÇϸé(ÀÚ), ¼¼¼ÇÀÌ Ã³¸®ÇÑ ¸ðµç ¸Þ¼¼Áö°¡ È®ÀÎ ÀÀ´äµË´Ï´Ù.
Ŭ¶óÀ̾ðÆ®ÀÇ È®ÀÎ ÀÀ´ä ¸ðµå¸¦ »ç¿ëÇϸé(ÀÚ), Ŭ¶óÀÌ¾ðÆ®´Â Ã³¸®¸¦ ½ÇÇàÇϰí ÀÖ´Â µ¿¾È¿¡ ´ë·®ÀÇ ¹ÌÈ®ÀÎ ÀÀ´ä ¸Þ¼¼Áö¸¦ ±¸ÃàÇÏ´Â °æ¿ì°¡ ÀÖ½À´Ï´Ù. JMS ÇÁ·Î¹ÙÀÌ´õ´Â Ŭ¶óÀ̾ðÆ®ÀÇ °úÀ× ½ÇÇàÀ» Á¦ÇÑÇÏ´Â ¼ö´ÜÀ» °ü¸®ÀÚ¿¡°Ô Á¦°øÇØ, Ŭ¶óÀÌ¾ðÆ®°¡ ¸®¼Ò½º¸¦ ´Ù ½á ¹ö¸®´Â °ÍÀ» ¸·¾Æ, »ç¿ëÁßÀÇ ¸®¼Ò½º°¡ ÀϽÃÀûÀ¸·Î ºí·Ï µÇ¾úÀ» °æ¿ì¿¡´Â È®½ÇÈ÷ 󸮸¦ ½ÇÆÐ½Ãų Çʿ䰡 ÀÖ½À´Ï´Ù.
Message.acknowledge()
public static final int DUPS_OK_ACKNOWLEDGE
¸Þ¼ÒµåÀÇ »ó¼¼ |
public BytesMessage createBytesMessage() throws JMSException
BytesMessage
¿ÀºêÁ§Æ®¸¦ ÀÛ¼ºÇÕ´Ï´Ù. BytesMessage
¿ÀºêÁ§Æ®¸¦ »ç¿ëÇØ, ¹ÌÇØ¼®ÀÇ ¾Æ¸£¹ÙÀÌÆ® ½Ã³Á¹°À» Æ÷ÇÔÇÑ ¸Þ¼¼Áö¸¦ ¼Û½ÅÇÒ ¼ö ÀÖ½À´Ï´Ù. JMSException
- ³»ºÎ ¿¡·¯¸¦ À§Çؼ(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ ÀÌ ¸Þ¼¼ÁöÀÇ ÀÛ¼º¿¡ ½ÇÆÐÇßÀ» °æ¿ìpublic MapMessage createMapMessage() throws JMSException
MapMessage
¿ÀºêÁ§Æ®¸¦ ÀÛ¼ºÇÕ´Ï´Ù. MapMessage
¿ÀºêÁ§Æ®¸¦ »ç¿ëÇØ, ÀÚ±â Á¤ÀÇÇüÀÇ À̸§°ú °ªÀÇ Æä¾î¼¼Æ®¸¦ ¼Û½ÅÇÒ ¼ö ÀÖ½À´Ï´Ù. ¿©±â¼, À̸§ ¹× °ªÀº °¢°¢ Java ÇÁ·Î±×·¥ ¾ð¾îÀÇ String
¿ÀºêÁ§Æ® ¹× ¿ø½ÃÀûÄ¡°¡ µË´Ï´Ù. JMSException
- ³»ºÎ ¿¡·¯¸¦ À§Çؼ(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ ÀÌ ¸Þ¼¼ÁöÀÇ ÀÛ¼º¿¡ ½ÇÆÐÇßÀ» °æ¿ìpublic Message createMessage() throws JMSException
Message
¿ÀºêÁ§Æ®¸¦ ÀÛ¼ºÇÕ´Ï´Ù. Message
ÀÎÅÍÆäÀ̽º´Â, ¸ðµç JMS ¸Þ¼¼ÁöÀÇ ·çÆ® ÀÎÅÍÆäÀ̽ºÀÔ´Ï´Ù. Message
¿ÀºêÁ§Æ®´Â, ¸ðµç Ç¥ÁØ ¸Þ¼¼ÁöÇì´õ Á¤º¸¸¦ º¸°ü À¯ÁöÇÕ´Ï´Ù. À̰ÍÀº, Çì´õ Á¤º¸¸¸À» Æ÷ÇÔÇÑ ¸Þ¼¼Áö·Î ÃæºÐÇÑ °æ¿ì¿¡ ¼Û½Å °¡´ÉÇÕ´Ï´Ù. JMSException
- ³»ºÎ ¿¡·¯¸¦ À§Çؼ(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ ÀÌ ¸Þ¼¼ÁöÀÇ ÀÛ¼º¿¡ ½ÇÆÐÇßÀ» °æ¿ìpublic ObjectMessage createObjectMessage() throws JMSException
ObjectMessage
¿ÀºêÁ§Æ®¸¦ ÀÛ¼ºÇÕ´Ï´Ù. ObjectMessage
¿ÀºêÁ§Æ®¸¦ »ç¿ëÇØ, Á÷·ÄÈ °¡´ÉÇÑ Java ¿ÀºêÁ§Æ®¸¦ Æ÷ÇÔÇÑ ¸Þ¼¼Áö¸¦ ¼Û½ÅÇÒ ¼ö ÀÖ½À´Ï´Ù. JMSException
- ³»ºÎ ¿¡·¯¸¦ À§Çؼ(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ ÀÌ ¸Þ¼¼ÁöÀÇ ÀÛ¼º¿¡ ½ÇÆÐÇßÀ» °æ¿ìpublic ObjectMessage createObjectMessage(java.io.Serializable object) throws JMSException
ObjectMessage
¿ÀºêÁ§Æ®¸¦ ÀÛ¼ºÇÕ´Ï´Ù. ObjectMessage
¿ÀºêÁ§Æ®¸¦ »ç¿ëÇØ, Á÷·ÄÈ °¡´ÉÇÑ Java ¿ÀºêÁ§Æ®¸¦ Æ÷ÇÔÇÑ ¸Þ¼¼Áö¸¦ ¼Û½ÅÇÒ ¼ö ÀÖ½À´Ï´Ù. object
- ÀÌ ¸Þ¼¼ÁöÀÇ ÃʱâÈ¿¡ »ç¿ëÇÏ´Â ¿ÀºêÁ§Æ®JMSException
- ³»ºÎ ¿¡·¯¸¦ À§Çؼ(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ ÀÌ ¸Þ¼¼ÁöÀÇ ÀÛ¼º¿¡ ½ÇÆÐÇßÀ» °æ¿ìpublic StreamMessage createStreamMessage() throws JMSException
StreamMessage
¿ÀºêÁ§Æ®¸¦ ÀÛ¼ºÇÕ´Ï´Ù. StreamMessage
¿ÀºêÁ§Æ®¸¦ »ç¿ëÇØ, Java ÇÁ·Î±×·¥ ¾ð¾î¿¡¼ÀÇ ¿ø½ÃÀûÄ¡¸¦ Æ÷ÇÔÇÑ ÀÚ±â Á¤ÀÇÇüÀÇ ½Ã³Á¹°À» ¼Û½ÅÇÒ ¼ö ÀÖ½À´Ï´Ù. JMSException
- ³»ºÎ ¿¡·¯¸¦ À§Çؼ(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ ÀÌ ¸Þ¼¼ÁöÀÇ ÀÛ¼º¿¡ ½ÇÆÐÇßÀ» °æ¿ìpublic TextMessage createTextMessage() throws JMSException
TextMessage
¿ÀºêÁ§Æ®¸¦ ÀÛ¼ºÇÕ´Ï´Ù. TextMessage
¿ÀºêÁ§Æ®¸¦ »ç¿ëÇØ,String
¿ÀºêÁ§Æ®¸¦ Æ÷ÇÔÇÑ ¸Þ¼¼Áö¸¦ ¼Û½ÅÇÒ ¼ö ÀÖ½À´Ï´Ù. JMSException
- ³»ºÎ ¿¡·¯¸¦ À§Çؼ(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ ÀÌ ¸Þ¼¼ÁöÀÇ ÀÛ¼º¿¡ ½ÇÆÐÇßÀ» °æ¿ìpublic TextMessage createTextMessage(java.lang.String text) throws JMSException
TextMessage
¿ÀºêÁ§Æ®¸¦ ÀÛ¼ºÇÕ´Ï´Ù. TextMessage
¿ÀºêÁ§Æ®¸¦ »ç¿ëÇØ,String
¸¦ Æ÷ÇÔÇÑ ¸Þ¼¼Áö¸¦ ¼Û½ÅÇÒ ¼ö ÀÖ½À´Ï´Ù. text
- ÀÌ ¸Þ¼¼ÁöÀÇ ÃʱâÈ¿¡ »ç¿ëÇϴ ij¸¯ÅÍ ¶óÀÎJMSException
- ³»ºÎ ¿¡·¯¸¦ À§Çؼ(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ ÀÌ ¸Þ¼¼ÁöÀÇ ÀÛ¼º¿¡ ½ÇÆÐÇßÀ» °æ¿ìpublic boolean getTransacted() throws JMSException
JMSException
- ³»ºÎ ¿¡·¯¸¦ À§Çؼ(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ Æ®·£Àè¼Ç(transaction) ¸ðµå¸¦ µ¹·ÁÁÖ´Â °Í¿¡ ½ÇÆÐÇßÀ» °æ¿ìpublic void commit() throws JMSException
JMSException
- ³»ºÎ ¿¡·¯¸¦ À§Çؼ(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ Æ®·£Àè¼Ç(transaction)ÀÇ À§Å¹¿¡ ½ÇÆÐÇßÀ» °æ¿ìTransactionRolledBackException
- À§Å¹½Ã¿¡, ³»ºÎ ¿¡·¯¸¦ À§Çؼ(¶§¹®¿¡) Æ®·£Àè¼Ç(transaction)°¡ ·Ñ¹é(rollback) µÇ¾úÀ» °æ¿ìIllegalStateException
- Æ®·£Àè¼Ç(transaction) ó¸®µÈ ¼¼¼Ç¿¡ ÀÇÇØ, ÀÌ ¸Þ¼Òµå°¡ ºÒ·Á °¡Áö ¾Ê¾Ò´ø °æ¿ìpublic void rollback() throws JMSException
JMSException
- ³»ºÎ ¿¡·¯¸¦ À§Çؼ(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ Æ®·£Àè¼Ç(transaction)ÀÇ ·Ñ¹é(rollback)¿¡ ½ÇÆÐÇßÀ» °æ¿ìIllegalStateException
- Æ®·£Àè¼Ç(transaction) ó¸®µÈ ¼¼¼Ç¿¡ ÀÇÇØ, ÀÌ ¸Þ¼Òµå°¡ ºÒ·Á °¡Áö ¾Ê¾Ò´ø °æ¿ìpublic void close() throws JMSException
JMS ÇÁ·Î¹ÙÀÌ´õ´Â, ¼¼¼Ç¿¡ ´ëÀÀÇÏ´Â ¸®¼Ò½º¸¦ JVM ¿ÜºÎ¿¡ ÇÒ´çÇÏ´Â °æ¿ì°¡ ÀÖ±â (À§ÇØ)¶§¹®¿¡, ¸®¼Ò½º°¡ ºÒÇÊ¿äÇÏ°Ô µÇ¾úÀ» °æ¿ì, Ŭ¶óÀÌ¾ðÆ®°¡ ¸®¼Ò½º¸¦ ´ÝÀ» Çʿ䰡 ÀÖ½À´Ï´Ù. ÀÌ·¯ÇÑ ¸®¼Ò½ºÀÇ ÀçÀÌ¿ëÀ» °¡º£Áö ÄÝ·º¼Ç¿¡ ¸Ã°åÀ» °æ¿ì, ÀûÀýÇÑ Å¸Àֿ̹¡ ÀçÀÌ¿ëÀ» ÇÑ´Ù°í´Â ÇÒ ¼ö ¾ø½À´Ï´Ù.
´ÝÀº ¼¼¼ÇÀÇ ÇÁ·Îµà»ç ¹× ÄÁ½´¸Ó(consumer)¸¦ ´ÝÀ» ÇÊ¿ä´Â ¾ø½À´Ï´Ù.
receive
ÀÇ È£ÃâÇØ ¶Ç´Â ½ÇÇàÁßÀÇ ¸Þ¼¼Áö ûÃëÀÚ°¡ ¿Ï·áÇÒ ¶§±îÁö, ÀÌ È£ÃâÀº ºí·ÏÀ» ½ÇÇàÇÕ´Ï´Ù. ÀÌ ¼¼¼ÇÀÌ ´ÝÇôÁö¸é(ÀÚ), ºí·Ï µÈ ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)ÀÇ receive
È£ÃâÀÌ null
¸¦ µ¹·ÁÁÝ´Ï´Ù.
Æ®·£Àè¼Ç(transaction) ó¸®µÈ ¼¼¼ÇÀ» ´Ý´Â °æ¿ì, ÁøÇàÁßÀÇ Æ®·£Àè¼Ç(transaction)¸¦ ·Ñ¹é(rollback) ÇÒ Çʿ䰡 ÀÖ½À´Ï´Ù.
ÀÌ ¸Þ¼Òµå´Â, µ¿½Ã¿¡ È£ÃâÇÒ ¼ö ÀÖ´Â À¯ÀÏÇÑ Session
¸Þ¼ÒµåÀÔ´Ï´Ù.
´ÝÀº ¼¼¼Ç¿¡ ´ëÇØ¼ ´Ù¸¥ Session
¸Þ¼Òµå¸¦ È£ÃâÇÏ´Â °æ¿ì,JMSException.IllegalStateException
¸¦ ½½·Î¿ì ÇÒ Çʿ䰡 ÀÖ½À´Ï´Ù. ´ÝÀº ¼¼¼ÇÀ» ´Ý¾Æµµ, ¿¹¿Ü¸¦ ½½·Î¿ì ½ÃÄѼ´Â ¾ÈµË´Ï´Ù.
JMSException
- ³»ºÎ ¿¡·¯¸¦ À§Çؼ(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ ¼¼¼ÇÀ» ´Ý´Â 󸮿¡ ½ÇÆÐÇßÀ» °æ¿ìpublic void recover() throws JMSException
¸ðµç ÄÁ½´¸Ó(consumer)°¡, ¸Þ¼¼Áö¸¦ ¿¬¼ÓÇÑ ¼ø¼·Î Àü´ÞÇÕ´Ï´Ù. ¼ö½ÅÇÑ ¸Þ¼¼Áö¸¦ È®ÀÎ ÀÀ´äÇϸé(ÀÚ), Ŭ¶óÀÌ¾ðÆ®¿¡ Àü´Þ ³¡³ ¸Þ¼¼Áö ¸ðµç °ÍÀÌ È®ÀÎ ÀÀ´äµË´Ï´Ù.
¼¼¼ÇÀ» Àç°³Çϸé(ÀÚ), ´ÙÀ½ÀÇ Á¶ÀÛÀÌ ½ÇÇàµË´Ï´Ù.
JMSException
- ³»ºÎ ¿¡·¯¸¦ À§Çؼ(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ ¸Þ¼¼Áö Àü´ÞÀÇ Á¤Áö ¹× Àç°³¿¡ ½ÇÆÐÇßÀ» °æ¿ìIllegalStateException
- Æ®·£Àè¼Ç(transaction) ó¸®µÈ ¼¼¼Ç¿¡ ÀÇÇØ, ÀÌ ¸Þ¼Òµå°¡ ºÒ·Á °¡´Â °æ¿ìpublic MessageListener getMessageListener() throws JMSException
JMSException
- ³»ºÎ ¿¡·¯¸¦ À§Çؼ(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ ¸Þ¼¼Áö ûÃëÀÚÀÇ Ãëµæ¿¡ ½ÇÆÐÇßÀ» °æ¿ìsetMessageListener(javax.jms.MessageListener)
,
ServerSessionPool
,
ServerSession
public void setMessageListener(MessageListener listener) throws JMSException
½Äº° ¸Þ¼¼Áö ûÃëÀÚ¸¦ ¼³Á¤Çϸé(ÀÚ), ÀÌ ¼¼¼Ç³»¿¡¼ ´Ù¸¥ ¸Þ¼¼Áö ¼ö½Å Çü½ÄÀ» »ç¿ëÇÒ ¼ö ¾ø°Ô µË´Ï´Ù. ´Ù¸¸, ¸Þ¼¼Áö ¼Û½Å¿¡ °üÇØ¼´Â, ¸ðµç Çü½ÄÀÌ °è¼ÓÇØ ¼Æ÷Æ®µË´Ï´Ù.
À̰ÍÀº, Åë»óÀÇ JMS Ŭ¶óÀÌ¾ðÆ®·ÎºÎÅÍ´Â »ç¿ëµÇÁö ¾Ê´Â »ó±ÞÀÚÀü¿ëÀÇ ±â´ÉÀÔ´Ï´Ù.
listener
- ÀÌ ¼¼¼Ç¿¡ °ü·ÃÁþ´Â ¸Þ¼¼Áö ûÃëÀÚJMSException
- ³»ºÎ ¿¡·¯¸¦ À§Çؼ(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ ¸Þ¼¼Áö ûÃëÀÚÀÇ ¼³Á¤¿¡ ½ÇÆÐÇßÀ» °æ¿ìgetMessageListener()
,
ServerSessionPool
,
ServerSession
public void run()
java.lang.Runnable
³»ÀÇ run
ServerSession
|
|||||||||
ÀüÀÇ Å¬·¡½º ´ÙÀ½ÀÇ Å¬·¡½º | ÇÁ·¹ÀÓ ÀÖ¾î ÇÁ·¹ÀÓ ¾øÀ½ | ||||||||
°³¿ä: ³»ºÎ Ŭ·¡½º | Çʵå | constructor¡¡ ¡¡ | ¸Þ¼Òµå | »ó¼¼: Çʵå | constructor¡¡ ¡¡ | ¸Þ¼Òµå |